Package io.hstream.internal

Class BatchedRecord.Builder

  • All Implemented Interfaces:
    com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, BatchedRecordOrBuilder, Cloneable
    Enclosing class:
    BatchedRecord
    public static final class BatchedRecord.Builder
extends com.google.protobuf.GeneratedMessageV3.Builder<BatchedRecord.Builder>
implements BatchedRecordOrBuilder
    Protobuf type hstream.server.BatchedRecord

    • Method Detail

      • getDescriptor

        public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

      • internalGetFieldAccessorTable

        protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
        Specified by:
        internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessageV3.Builder<BatchedRecord.Builder>

      • clear

        public BatchedRecord.Builder clear()
        Specified by:
        clear in interface com.google.protobuf.Message.Builder
        Specified by:
        clear in interface com.google.protobuf.MessageLite.Builder
        Overrides:
        clear in class com.google.protobuf.GeneratedMessageV3.Builder<BatchedRecord.Builder>

      • getDescriptorForType

        public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
        Specified by:
        getDescriptorForType in interface com.google.protobuf.Message.Builder
        Specified by:
        getDescriptorForType in interface com.google.protobuf.MessageOrBuilder
        Overrides:
        getDescriptorForType in class com.google.protobuf.GeneratedMessageV3.Builder<BatchedRecord.Builder>

      • getDefaultInstanceForType

        public BatchedRecord getDefaultInstanceForType()
        Specified by:
        getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
        Specified by:
        getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

      • build

        public BatchedRecord build()
        Specified by:
        build in interface com.google.protobuf.Message.Builder
        Specified by:
        build in interface com.google.protobuf.MessageLite.Builder

      • buildPartial

        public BatchedRecord buildPartial()
        Specified by:
        buildPartial in interface com.google.protobuf.Message.Builder
        Specified by:
        buildPartial in interface com.google.protobuf.MessageLite.Builder

      • mergeFrom

        public BatchedRecord.Builder mergeFrom​(com.google.protobuf.Message other)
        Specified by:
        mergeFrom in interface com.google.protobuf.Message.Builder
        Overrides:
        mergeFrom in class com.google.protobuf.AbstractMessage.Builder<BatchedRecord.Builder>

      • isInitialized

        public final boolean isInitialized()
        Specified by:
        isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
        Overrides:
        isInitialized in class com.google.protobuf.GeneratedMessageV3.Builder<BatchedRecord.Builder>

      • mergeFrom

        public BatchedRecord.Builder mergeFrom​(com.google.protobuf.CodedInputStream input,
                                       com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                throws IOException
        Specified by:
        mergeFrom in interface com.google.protobuf.Message.Builder
        Specified by:
        mergeFrom in interface com.google.protobuf.MessageLite.Builder
        Overrides:
        mergeFrom in class com.google.protobuf.AbstractMessage.Builder<BatchedRecord.Builder>
        Throws:
        IOException

      • getCompressionTypeValue

        public int getCompressionTypeValue()
        .hstream.server.CompressionType compressionType = 1;
        Specified by:
        getCompressionTypeValue in interface BatchedRecordOrBuilder
        Returns:
        The enum numeric value on the wire for compressionType.

      • setCompressionTypeValue

        public BatchedRecord.Builder setCompressionTypeValue​(int value)
        .hstream.server.CompressionType compressionType = 1;
        Parameters:
        value - The enum numeric value on the wire for compressionType to set.
        Returns:
        This builder for chaining.

      • setCompressionType

        public BatchedRecord.Builder setCompressionType​(CompressionType value)
        .hstream.server.CompressionType compressionType = 1;
        Parameters:
        value - The compressionType to set.
        Returns:
        This builder for chaining.

      • clearCompressionType

        public BatchedRecord.Builder clearCompressionType()
        .hstream.server.CompressionType compressionType = 1;
        Returns:
        This builder for chaining.

      • hasPublishTime

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

      • getPublishTime

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

      • setPublishTime

        public BatchedRecord.Builder setPublishTime​(com.google.protobuf.Timestamp value)
         Required.
 The time at which the message was published,
 populated by the server.
        .google.protobuf.Timestamp publishTime = 2;

      • setPublishTime

        public BatchedRecord.Builder setPublishTime​(com.google.protobuf.Timestamp.Builder builderForValue)
         Required.
 The time at which the message was published,
 populated by the server.
        .google.protobuf.Timestamp publishTime = 2;

      • mergePublishTime

        public BatchedRecord.Builder mergePublishTime​(com.google.protobuf.Timestamp value)
         Required.
 The time at which the message was published,
 populated by the server.
        .google.protobuf.Timestamp publishTime = 2;

      • clearPublishTime

        public BatchedRecord.Builder clearPublishTime()
         Required.
 The time at which the message was published,
 populated by the server.
        .google.protobuf.Timestamp publishTime = 2;

      • getPublishTimeBuilder

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

      • getPublishTimeOrBuilder

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

      • getBatchSize

        public 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;
        Specified by:
        getBatchSize in interface BatchedRecordOrBuilder
        Returns:
        The batchSize.

      • setBatchSize

        public BatchedRecord.Builder setBatchSize​(int value)
         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;
        Parameters:
        value - The batchSize to set.
        Returns:
        This builder for chaining.

      • clearBatchSize

        public BatchedRecord.Builder clearBatchSize()
         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:
        This builder for chaining.

      • getPayload

        public com.google.protobuf.ByteString getPayload()
         serialized BatchHStreamRecords
        bytes payload = 4;
        Specified by:
        getPayload in interface BatchedRecordOrBuilder
        Returns:
        The payload.

      • setPayload

        public BatchedRecord.Builder setPayload​(com.google.protobuf.ByteString value)
         serialized BatchHStreamRecords
        bytes payload = 4;
        Parameters:
        value - The payload to set.
        Returns:
        This builder for chaining.

      • clearPayload

        public BatchedRecord.Builder clearPayload()
         serialized BatchHStreamRecords
        bytes payload = 4;
        Returns:
        This builder for chaining.

      • setUnknownFields

        public final BatchedRecord.Builder setUnknownFields​(com.google.protobuf.UnknownFieldSet unknownFields)
        Specified by:
        setUnknownFields in interface com.google.protobuf.Message.Builder
        Overrides:
        setUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<BatchedRecord.Builder>

      • mergeUnknownFields

        public final BatchedRecord.Builder mergeUnknownFields​(com.google.protobuf.UnknownFieldSet unknownFields)
        Specified by:
        mergeUnknownFields in interface com.google.protobuf.Message.Builder
        Overrides:
        mergeUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<BatchedRecord.Builder>