Class 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 Detail


        public static final int LATEST_SCHEMA_VERSION_FOR_COMPUTE_REQUEST
        See Also:
        Constant Field Values
    • Constructor Detail

      • ComputeRequestWrapper

        public ComputeRequestWrapper​(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()
      • getValueSchema

        public org.apache.avro.Schema getValueSchema()
      • getOperationResultFields

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

        public boolean isRequestOriginallyStreaming()