Package s2.v1
Class ReadBatch
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite
-
- com.google.protobuf.AbstractMessage
-
- com.google.protobuf.GeneratedMessage
-
- s2.v1.ReadBatch
-
- All Implemented Interfaces:
com.google.protobuf.Message,com.google.protobuf.MessageLite,com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder,java.io.Serializable,ReadBatchOrBuilder
public final class ReadBatch extends com.google.protobuf.GeneratedMessage implements ReadBatchOrBuilder
Success response message to a Read request.
Protobuf types2.v1.ReadBatch- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classReadBatch.BuilderSuccess response message to a Read request.-
Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessage
com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingT extends com.google.protobuf.Message,T extends java.lang.Object>, com.google.protobuf.GeneratedMessage.UnusedPrivateParameter
-
-
Field Summary
Fields Modifier and Type Field Description static intRECORDS_FIELD_NUMBERstatic intTAIL_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(java.lang.Object obj)static ReadBatchgetDefaultInstance()ReadBatchgetDefaultInstanceForType()static com.google.protobuf.Descriptors.DescriptorgetDescriptor()com.google.protobuf.Parser<ReadBatch>getParserForType()SequencedRecordgetRecords(int index)Records that are at or after the requested start position.intgetRecordsCount()Records that are at or after the requested start position.java.util.List<SequencedRecord>getRecordsList()Records that are at or after the requested start position.SequencedRecordOrBuildergetRecordsOrBuilder(int index)Records that are at or after the requested start position.java.util.List<? extends SequencedRecordOrBuilder>getRecordsOrBuilderList()Records that are at or after the requested start position.intgetSerializedSize()StreamPositiongetTail()Sequence number that will be assigned to the next record on the stream, and timestamp of the last record.StreamPositionOrBuildergetTailOrBuilder()Sequence number that will be assigned to the next record on the stream, and timestamp of the last record.inthashCode()booleanhasTail()Sequence number that will be assigned to the next record on the stream, and timestamp of the last record.protected com.google.protobuf.GeneratedMessage.FieldAccessorTableinternalGetFieldAccessorTable()booleanisInitialized()static ReadBatch.BuildernewBuilder()static ReadBatch.BuildernewBuilder(ReadBatch prototype)ReadBatch.BuildernewBuilderForType()protected ReadBatch.BuildernewBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent)static ReadBatchparseDelimitedFrom(java.io.InputStream input)static ReadBatchparseDelimitedFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static ReadBatchparseFrom(byte[] data)static ReadBatchparseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static ReadBatchparseFrom(com.google.protobuf.ByteString data)static ReadBatchparseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static ReadBatchparseFrom(com.google.protobuf.CodedInputStream input)static ReadBatchparseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static ReadBatchparseFrom(java.io.InputStream input)static ReadBatchparseFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static ReadBatchparseFrom(java.nio.ByteBuffer data)static ReadBatchparseFrom(java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)static com.google.protobuf.Parser<ReadBatch>parser()ReadBatch.BuildertoBuilder()voidwriteTo(com.google.protobuf.CodedOutputStream output)-
Methods inherited from class com.google.protobuf.GeneratedMessage
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, internalGetMapField, internalGetMapFieldReflection, isStringEmpty, makeMutableCopy, makeMutableCopy, mergeFromAndMakeImmutableInternal, newFileScopedGeneratedExtension, newInstance, newMessageScopedGeneratedExtension, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag
-
Methods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, hashFields, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite
addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
RECORDS_FIELD_NUMBER
public static final int RECORDS_FIELD_NUMBER
- See Also:
- Constant Field Values
-
TAIL_FIELD_NUMBER
public static final int TAIL_FIELD_NUMBER
- See Also:
- Constant Field Values
-
-
Method Detail
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessage
-
getRecordsList
public java.util.List<SequencedRecord> getRecordsList()
Records that are at or after the requested start position.
repeated .s2.v1.SequencedRecord records = 1;- Specified by:
getRecordsListin interfaceReadBatchOrBuilder
-
getRecordsOrBuilderList
public java.util.List<? extends SequencedRecordOrBuilder> getRecordsOrBuilderList()
Records that are at or after the requested start position.
repeated .s2.v1.SequencedRecord records = 1;- Specified by:
getRecordsOrBuilderListin interfaceReadBatchOrBuilder
-
getRecordsCount
public int getRecordsCount()
Records that are at or after the requested start position.
repeated .s2.v1.SequencedRecord records = 1;- Specified by:
getRecordsCountin interfaceReadBatchOrBuilder
-
getRecords
public SequencedRecord getRecords(int index)
Records that are at or after the requested start position.
repeated .s2.v1.SequencedRecord records = 1;- Specified by:
getRecordsin interfaceReadBatchOrBuilder
-
getRecordsOrBuilder
public SequencedRecordOrBuilder getRecordsOrBuilder(int index)
Records that are at or after the requested start position.
repeated .s2.v1.SequencedRecord records = 1;- Specified by:
getRecordsOrBuilderin interfaceReadBatchOrBuilder
-
hasTail
public boolean hasTail()
Sequence number that will be assigned to the next record on the stream, and timestamp of the last record. This will only be present when consuming recent records.
optional .s2.v1.StreamPosition tail = 2;- Specified by:
hasTailin interfaceReadBatchOrBuilder- Returns:
- Whether the tail field is set.
-
getTail
public StreamPosition getTail()
Sequence number that will be assigned to the next record on the stream, and timestamp of the last record. This will only be present when consuming recent records.
optional .s2.v1.StreamPosition tail = 2;- Specified by:
getTailin interfaceReadBatchOrBuilder- Returns:
- The tail.
-
getTailOrBuilder
public StreamPositionOrBuilder getTailOrBuilder()
Sequence number that will be assigned to the next record on the stream, and timestamp of the last record. This will only be present when consuming recent records.
optional .s2.v1.StreamPosition tail = 2;- Specified by:
getTailOrBuilderin interfaceReadBatchOrBuilder
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessage
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException- Specified by:
writeToin interfacecom.google.protobuf.MessageLite- Overrides:
writeToin classcom.google.protobuf.GeneratedMessage- Throws:
java.io.IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSizein interfacecom.google.protobuf.MessageLite- Overrides:
getSerializedSizein classcom.google.protobuf.GeneratedMessage
-
equals
public boolean equals(java.lang.Object obj)
- Specified by:
equalsin interfacecom.google.protobuf.Message- Overrides:
equalsin classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCodein interfacecom.google.protobuf.Message- Overrides:
hashCodein classcom.google.protobuf.AbstractMessage
-
parseFrom
public static ReadBatch parseFrom(java.nio.ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ReadBatch parseFrom(java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ReadBatch parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ReadBatch parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ReadBatch parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ReadBatch parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ReadBatch parseFrom(java.io.InputStream input) throws java.io.IOException
- Throws:
java.io.IOException
-
parseFrom
public static ReadBatch parseFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
- Throws:
java.io.IOException
-
parseDelimitedFrom
public static ReadBatch parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException
- Throws:
java.io.IOException
-
parseDelimitedFrom
public static ReadBatch parseDelimitedFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
- Throws:
java.io.IOException
-
parseFrom
public static ReadBatch parseFrom(com.google.protobuf.CodedInputStream input) throws java.io.IOException
- Throws:
java.io.IOException
-
parseFrom
public static ReadBatch parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
- Throws:
java.io.IOException
-
newBuilderForType
public ReadBatch.Builder newBuilderForType()
- Specified by:
newBuilderForTypein interfacecom.google.protobuf.Message- Specified by:
newBuilderForTypein interfacecom.google.protobuf.MessageLite
-
newBuilder
public static ReadBatch.Builder newBuilder()
-
newBuilder
public static ReadBatch.Builder newBuilder(ReadBatch prototype)
-
toBuilder
public ReadBatch.Builder toBuilder()
- Specified by:
toBuilderin interfacecom.google.protobuf.Message- Specified by:
toBuilderin interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected ReadBatch.Builder newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent)
- Overrides:
newBuilderForTypein classcom.google.protobuf.AbstractMessage
-
getDefaultInstance
public static ReadBatch getDefaultInstance()
-
parser
public static com.google.protobuf.Parser<ReadBatch> parser()
-
getParserForType
public com.google.protobuf.Parser<ReadBatch> getParserForType()
- Specified by:
getParserForTypein interfacecom.google.protobuf.Message- Specified by:
getParserForTypein interfacecom.google.protobuf.MessageLite- Overrides:
getParserForTypein classcom.google.protobuf.GeneratedMessage
-
getDefaultInstanceForType
public ReadBatch getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
-