Package com.linkedin.venice.compute

Class ComputeRequestWrapper

java.lang.Object

com.linkedin.venice.compute.ComputeRequestWrapper

public class ComputeRequestWrapper
extends java.lang.Object

This class is used by the client to encapsulate the information it needs about a compute request. N.B.: This class used to contain multiple versions of the ComputeRequestV3 but it was not necessary since all the versions were anyway compatible with one another. We are now keeping only the latest version used on the wire, which is 3 (version 4 was never used as a wire protocol). We can always revisit this if the need to evolve read compute comes into play.

Field Summary

Fields

Modifier and Type	Field	Description
static int	LATEST_SCHEMA_VERSION_FOR_COMPUTE_REQUEST

Constructor Summary

Constructors

Constructor	Description
ComputeRequestWrapper(int valueSchemaId, org.apache.avro.Schema valueSchema, org.apache.avro.Schema resultSchema, java.lang.String resultSchemaString, java.util.List<ComputeOperation> operations, boolean originallyStreaming)

Method Summary

Modifier and Type	Method	Description
java.util.List<org.apache.avro.Schema.Field>	getOperationResultFields()
java.util.List<ComputeOperation>	getOperations()
java.lang.CharSequence	getResultSchemaStr()
org.apache.avro.Schema	getValueSchema()
int	getValueSchemaID()
boolean	isRequestOriginallyStreaming()
byte[]	serialize()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LATEST_SCHEMA_VERSION_FOR_COMPUTE_REQUEST

public static final int LATEST_SCHEMA_VERSION_FOR_COMPUTE_REQUEST

See Also:

Constant Field Values

Constructor Detail

ComputeRequestWrapper

public ComputeRequestWrapper(int valueSchemaId,
                             org.apache.avro.Schema valueSchema,
                             org.apache.avro.Schema resultSchema,
                             java.lang.String resultSchemaString,
                             java.util.List<ComputeOperation> operations,
                             boolean originallyStreaming)

Method Detail

serialize

public byte[] serialize()

getResultSchemaStr

public java.lang.CharSequence getResultSchemaStr()

getValueSchemaID

public int getValueSchemaID()

getValueSchema

public org.apache.avro.Schema getValueSchema()

getOperations

public java.util.List<ComputeOperation> getOperations()

getOperationResultFields

public java.util.List<org.apache.avro.Schema.Field> getOperationResultFields()

isRequestOriginallyStreaming

public boolean isRequestOriginallyStreaming()