Package com.linkedin.venice.compute

Class ComputeRequestWrapper

java.lang.Object

com.linkedin.venice.compute.ComputeRequestWrapper

public class ComputeRequestWrapper
extends 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 final 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, String resultSchemaString, List<ComputeOperation> operations, boolean originallyStreaming)

Method Summary

Modifier and Type	Method	Description
List<org.apache.avro.Schema.Field>	getOperationResultFields()
List<ComputeOperation>	getOperations()
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 Details

LATEST_SCHEMA_VERSION_FOR_COMPUTE_REQUEST

public static final int LATEST_SCHEMA_VERSION_FOR_COMPUTE_REQUEST

See Also:

• Constant Field Values

Constructor Details

ComputeRequestWrapper

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

Method Details

serialize

public byte[] serialize()

getResultSchemaStr

public CharSequence getResultSchemaStr()

getValueSchemaID

public int getValueSchemaID()

getValueSchema

public org.apache.avro.Schema getValueSchema()

getOperations

public List<ComputeOperation> getOperations()

getOperationResultFields

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

isRequestOriginallyStreaming

public boolean isRequestOriginallyStreaming()