Package io.hstream.internal
Class StreamingFetchRequest.Builder
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite.Builder
-
- com.google.protobuf.AbstractMessage.Builder<BuilderT>
-
- com.google.protobuf.GeneratedMessageV3.Builder<StreamingFetchRequest.Builder>
-
- io.hstream.internal.StreamingFetchRequest.Builder
-
- All Implemented Interfaces:
com.google.protobuf.Message.Builder,com.google.protobuf.MessageLite.Builder,com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder,StreamingFetchRequestOrBuilder,Cloneable
- Enclosing class:
- StreamingFetchRequest
public static final class StreamingFetchRequest.Builder extends com.google.protobuf.GeneratedMessageV3.Builder<StreamingFetchRequest.Builder> implements StreamingFetchRequestOrBuilder
Protobuf typehstream.server.StreamingFetchRequest
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description StreamingFetchRequest.BuilderaddAckIds(int index, RecordId value)repeated .hstream.server.RecordId ackIds = 3;StreamingFetchRequest.BuilderaddAckIds(int index, RecordId.Builder builderForValue)repeated .hstream.server.RecordId ackIds = 3;StreamingFetchRequest.BuilderaddAckIds(RecordId value)repeated .hstream.server.RecordId ackIds = 3;StreamingFetchRequest.BuilderaddAckIds(RecordId.Builder builderForValue)repeated .hstream.server.RecordId ackIds = 3;RecordId.BuilderaddAckIdsBuilder()repeated .hstream.server.RecordId ackIds = 3;RecordId.BuilderaddAckIdsBuilder(int index)repeated .hstream.server.RecordId ackIds = 3;StreamingFetchRequest.BuilderaddAllAckIds(Iterable<? extends RecordId> values)repeated .hstream.server.RecordId ackIds = 3;StreamingFetchRequestbuild()StreamingFetchRequestbuildPartial()StreamingFetchRequest.Builderclear()StreamingFetchRequest.BuilderclearAckIds()repeated .hstream.server.RecordId ackIds = 3;StreamingFetchRequest.BuilderclearConsumerName()string consumerName = 2;StreamingFetchRequest.BuilderclearSubscriptionId()string subscriptionId = 1;RecordIdgetAckIds(int index)repeated .hstream.server.RecordId ackIds = 3;RecordId.BuildergetAckIdsBuilder(int index)repeated .hstream.server.RecordId ackIds = 3;List<RecordId.Builder>getAckIdsBuilderList()repeated .hstream.server.RecordId ackIds = 3;intgetAckIdsCount()repeated .hstream.server.RecordId ackIds = 3;List<RecordId>getAckIdsList()repeated .hstream.server.RecordId ackIds = 3;RecordIdOrBuildergetAckIdsOrBuilder(int index)repeated .hstream.server.RecordId ackIds = 3;List<? extends RecordIdOrBuilder>getAckIdsOrBuilderList()repeated .hstream.server.RecordId ackIds = 3;StringgetConsumerName()string consumerName = 2;com.google.protobuf.ByteStringgetConsumerNameBytes()string consumerName = 2;StreamingFetchRequestgetDefaultInstanceForType()static com.google.protobuf.Descriptors.DescriptorgetDescriptor()com.google.protobuf.Descriptors.DescriptorgetDescriptorForType()StringgetSubscriptionId()string subscriptionId = 1;com.google.protobuf.ByteStringgetSubscriptionIdBytes()string subscriptionId = 1;protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTableinternalGetFieldAccessorTable()booleanisInitialized()StreamingFetchRequest.BuildermergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)StreamingFetchRequest.BuildermergeFrom(com.google.protobuf.Message other)StreamingFetchRequest.BuildermergeFrom(StreamingFetchRequest other)StreamingFetchRequest.BuildermergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)StreamingFetchRequest.BuilderremoveAckIds(int index)repeated .hstream.server.RecordId ackIds = 3;StreamingFetchRequest.BuildersetAckIds(int index, RecordId value)repeated .hstream.server.RecordId ackIds = 3;StreamingFetchRequest.BuildersetAckIds(int index, RecordId.Builder builderForValue)repeated .hstream.server.RecordId ackIds = 3;StreamingFetchRequest.BuildersetConsumerName(String value)string consumerName = 2;StreamingFetchRequest.BuildersetConsumerNameBytes(com.google.protobuf.ByteString value)string consumerName = 2;StreamingFetchRequest.BuildersetSubscriptionId(String value)string subscriptionId = 1;StreamingFetchRequest.BuildersetSubscriptionIdBytes(com.google.protobuf.ByteString value)string subscriptionId = 1;StreamingFetchRequest.BuildersetUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)-
Methods inherited from class com.google.protobuf.GeneratedMessageV3.Builder
addRepeatedField, clearField, clearOneof, clone, getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, getUnknownFieldSetBuilder, hasField, hasOneof, internalGetMapField, internalGetMutableMapField, isClean, markClean, mergeUnknownLengthDelimitedField, mergeUnknownVarintField, newBuilderForField, onBuilt, onChanged, parseUnknownField, setField, setRepeatedField, setUnknownFieldSetBuilder, setUnknownFieldsProto3
-
Methods inherited from class com.google.protobuf.AbstractMessage.Builder
findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder
addAll, addAll, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, newUninitializedMessageException
-
Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
-
-
Method Detail
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessageV3.Builder<StreamingFetchRequest.Builder>
-
clear
public StreamingFetchRequest.Builder clear()
- Specified by:
clearin interfacecom.google.protobuf.Message.Builder- Specified by:
clearin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
clearin classcom.google.protobuf.GeneratedMessageV3.Builder<StreamingFetchRequest.Builder>
-
getDescriptorForType
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.Message.Builder- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.MessageOrBuilder- Overrides:
getDescriptorForTypein classcom.google.protobuf.GeneratedMessageV3.Builder<StreamingFetchRequest.Builder>
-
getDefaultInstanceForType
public StreamingFetchRequest getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
build
public StreamingFetchRequest build()
- Specified by:
buildin interfacecom.google.protobuf.Message.Builder- Specified by:
buildin interfacecom.google.protobuf.MessageLite.Builder
-
buildPartial
public StreamingFetchRequest buildPartial()
- Specified by:
buildPartialin interfacecom.google.protobuf.Message.Builder- Specified by:
buildPartialin interfacecom.google.protobuf.MessageLite.Builder
-
mergeFrom
public StreamingFetchRequest.Builder mergeFrom(com.google.protobuf.Message other)
- Specified by:
mergeFromin interfacecom.google.protobuf.Message.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<StreamingFetchRequest.Builder>
-
mergeFrom
public StreamingFetchRequest.Builder mergeFrom(StreamingFetchRequest other)
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessageV3.Builder<StreamingFetchRequest.Builder>
-
mergeFrom
public StreamingFetchRequest.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
- Specified by:
mergeFromin interfacecom.google.protobuf.Message.Builder- Specified by:
mergeFromin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<StreamingFetchRequest.Builder>- Throws:
IOException
-
getSubscriptionId
public String getSubscriptionId()
string subscriptionId = 1;- Specified by:
getSubscriptionIdin interfaceStreamingFetchRequestOrBuilder- Returns:
- The subscriptionId.
-
getSubscriptionIdBytes
public com.google.protobuf.ByteString getSubscriptionIdBytes()
string subscriptionId = 1;- Specified by:
getSubscriptionIdBytesin interfaceStreamingFetchRequestOrBuilder- Returns:
- The bytes for subscriptionId.
-
setSubscriptionId
public StreamingFetchRequest.Builder setSubscriptionId(String value)
string subscriptionId = 1;- Parameters:
value- The subscriptionId to set.- Returns:
- This builder for chaining.
-
clearSubscriptionId
public StreamingFetchRequest.Builder clearSubscriptionId()
string subscriptionId = 1;- Returns:
- This builder for chaining.
-
setSubscriptionIdBytes
public StreamingFetchRequest.Builder setSubscriptionIdBytes(com.google.protobuf.ByteString value)
string subscriptionId = 1;- Parameters:
value- The bytes for subscriptionId to set.- Returns:
- This builder for chaining.
-
getConsumerName
public String getConsumerName()
string consumerName = 2;- Specified by:
getConsumerNamein interfaceStreamingFetchRequestOrBuilder- Returns:
- The consumerName.
-
getConsumerNameBytes
public com.google.protobuf.ByteString getConsumerNameBytes()
string consumerName = 2;- Specified by:
getConsumerNameBytesin interfaceStreamingFetchRequestOrBuilder- Returns:
- The bytes for consumerName.
-
setConsumerName
public StreamingFetchRequest.Builder setConsumerName(String value)
string consumerName = 2;- Parameters:
value- The consumerName to set.- Returns:
- This builder for chaining.
-
clearConsumerName
public StreamingFetchRequest.Builder clearConsumerName()
string consumerName = 2;- Returns:
- This builder for chaining.
-
setConsumerNameBytes
public StreamingFetchRequest.Builder setConsumerNameBytes(com.google.protobuf.ByteString value)
string consumerName = 2;- Parameters:
value- The bytes for consumerName to set.- Returns:
- This builder for chaining.
-
getAckIdsList
public List<RecordId> getAckIdsList()
repeated .hstream.server.RecordId ackIds = 3;- Specified by:
getAckIdsListin interfaceStreamingFetchRequestOrBuilder
-
getAckIdsCount
public int getAckIdsCount()
repeated .hstream.server.RecordId ackIds = 3;- Specified by:
getAckIdsCountin interfaceStreamingFetchRequestOrBuilder
-
getAckIds
public RecordId getAckIds(int index)
repeated .hstream.server.RecordId ackIds = 3;- Specified by:
getAckIdsin interfaceStreamingFetchRequestOrBuilder
-
setAckIds
public StreamingFetchRequest.Builder setAckIds(int index, RecordId value)
repeated .hstream.server.RecordId ackIds = 3;
-
setAckIds
public StreamingFetchRequest.Builder setAckIds(int index, RecordId.Builder builderForValue)
repeated .hstream.server.RecordId ackIds = 3;
-
addAckIds
public StreamingFetchRequest.Builder addAckIds(RecordId value)
repeated .hstream.server.RecordId ackIds = 3;
-
addAckIds
public StreamingFetchRequest.Builder addAckIds(int index, RecordId value)
repeated .hstream.server.RecordId ackIds = 3;
-
addAckIds
public StreamingFetchRequest.Builder addAckIds(RecordId.Builder builderForValue)
repeated .hstream.server.RecordId ackIds = 3;
-
addAckIds
public StreamingFetchRequest.Builder addAckIds(int index, RecordId.Builder builderForValue)
repeated .hstream.server.RecordId ackIds = 3;
-
addAllAckIds
public StreamingFetchRequest.Builder addAllAckIds(Iterable<? extends RecordId> values)
repeated .hstream.server.RecordId ackIds = 3;
-
clearAckIds
public StreamingFetchRequest.Builder clearAckIds()
repeated .hstream.server.RecordId ackIds = 3;
-
removeAckIds
public StreamingFetchRequest.Builder removeAckIds(int index)
repeated .hstream.server.RecordId ackIds = 3;
-
getAckIdsBuilder
public RecordId.Builder getAckIdsBuilder(int index)
repeated .hstream.server.RecordId ackIds = 3;
-
getAckIdsOrBuilder
public RecordIdOrBuilder getAckIdsOrBuilder(int index)
repeated .hstream.server.RecordId ackIds = 3;- Specified by:
getAckIdsOrBuilderin interfaceStreamingFetchRequestOrBuilder
-
getAckIdsOrBuilderList
public List<? extends RecordIdOrBuilder> getAckIdsOrBuilderList()
repeated .hstream.server.RecordId ackIds = 3;- Specified by:
getAckIdsOrBuilderListin interfaceStreamingFetchRequestOrBuilder
-
addAckIdsBuilder
public RecordId.Builder addAckIdsBuilder()
repeated .hstream.server.RecordId ackIds = 3;
-
addAckIdsBuilder
public RecordId.Builder addAckIdsBuilder(int index)
repeated .hstream.server.RecordId ackIds = 3;
-
getAckIdsBuilderList
public List<RecordId.Builder> getAckIdsBuilderList()
repeated .hstream.server.RecordId ackIds = 3;
-
setUnknownFields
public final StreamingFetchRequest.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
- Specified by:
setUnknownFieldsin interfacecom.google.protobuf.Message.Builder- Overrides:
setUnknownFieldsin classcom.google.protobuf.GeneratedMessageV3.Builder<StreamingFetchRequest.Builder>
-
mergeUnknownFields
public final StreamingFetchRequest.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
- Specified by:
mergeUnknownFieldsin interfacecom.google.protobuf.Message.Builder- Overrides:
mergeUnknownFieldsin classcom.google.protobuf.GeneratedMessageV3.Builder<StreamingFetchRequest.Builder>
-
-