Package io.hstream.internal

Interface BatchedRecordOrBuilder

  • All Superinterfaces:
    com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
    All Known Implementing Classes:
    BatchedRecord, BatchedRecord.Builder
    public interface BatchedRecordOrBuilder
extends com.google.protobuf.MessageOrBuilder

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      int getBatchSize()
      Required batchSize records the number of compressed HStreamRecords in the current batch.
      CompressionType getCompressionType()
      .hstream.server.CompressionType compressionType = 1;
      int getCompressionTypeValue()
      .hstream.server.CompressionType compressionType = 1;
      com.google.protobuf.ByteString getPayload()
      serialized BatchHStreamRecords
      com.google.protobuf.Timestamp getPublishTime()
      Required.
      com.google.protobuf.TimestampOrBuilder getPublishTimeOrBuilder()
      Required.
      boolean hasPublishTime()
      Required.

      • Methods inherited from interface com.google.protobuf.MessageLiteOrBuilder

        isInitialized

      • Methods inherited from interface com.google.protobuf.MessageOrBuilder

        findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

    • Method Detail

      • getCompressionTypeValue

        int getCompressionTypeValue()
        .hstream.server.CompressionType compressionType = 1;
        Returns:
        The enum numeric value on the wire for compressionType.

      • getCompressionType

        CompressionType getCompressionType()
        .hstream.server.CompressionType compressionType = 1;
        Returns:
        The compressionType.

      • hasPublishTime

        boolean hasPublishTime()
         Required.
 The time at which the message was published,
 populated by the server.
        .google.protobuf.Timestamp publishTime = 2;
        Returns:
        Whether the publishTime field is set.

      • getPublishTime

        com.google.protobuf.Timestamp getPublishTime()
         Required.
 The time at which the message was published,
 populated by the server.
        .google.protobuf.Timestamp publishTime = 2;
        Returns:
        The publishTime.

      • getPublishTimeOrBuilder

        com.google.protobuf.TimestampOrBuilder getPublishTimeOrBuilder()
         Required.
 The time at which the message was published,
 populated by the server.
        .google.protobuf.Timestamp publishTime = 2;

      • getBatchSize

        int getBatchSize()
         Required
 batchSize records the number of compressed HStreamRecords
 in the current batch. This field allows the server to build
 the RecordId correctly without decompression after reading
 the data from the store.
        uint32 batchSize = 3;
        Returns:
        The batchSize.

      • getPayload

        com.google.protobuf.ByteString getPayload()
         serialized BatchHStreamRecords
        bytes payload = 4;
        Returns:
        The payload.