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.Builder
addAckIds(int index, RecordId value)
repeated .hstream.server.RecordId ackIds = 3;
StreamingFetchRequest.Builder
addAckIds(int index, RecordId.Builder builderForValue)
repeated .hstream.server.RecordId ackIds = 3;
StreamingFetchRequest.Builder
addAckIds(RecordId value)
repeated .hstream.server.RecordId ackIds = 3;
StreamingFetchRequest.Builder
addAckIds(RecordId.Builder builderForValue)
repeated .hstream.server.RecordId ackIds = 3;
RecordId.Builder
addAckIdsBuilder()
repeated .hstream.server.RecordId ackIds = 3;
RecordId.Builder
addAckIdsBuilder(int index)
repeated .hstream.server.RecordId ackIds = 3;
StreamingFetchRequest.Builder
addAllAckIds(Iterable<? extends RecordId> values)
repeated .hstream.server.RecordId ackIds = 3;
StreamingFetchRequest
build()
StreamingFetchRequest
buildPartial()
StreamingFetchRequest.Builder
clear()
StreamingFetchRequest.Builder
clearAckIds()
repeated .hstream.server.RecordId ackIds = 3;
StreamingFetchRequest.Builder
clearConsumerName()
string consumerName = 2;
StreamingFetchRequest.Builder
clearSubscriptionId()
string subscriptionId = 1;
RecordId
getAckIds(int index)
repeated .hstream.server.RecordId ackIds = 3;
RecordId.Builder
getAckIdsBuilder(int index)
repeated .hstream.server.RecordId ackIds = 3;
List<RecordId.Builder>
getAckIdsBuilderList()
repeated .hstream.server.RecordId ackIds = 3;
int
getAckIdsCount()
repeated .hstream.server.RecordId ackIds = 3;
List<RecordId>
getAckIdsList()
repeated .hstream.server.RecordId ackIds = 3;
RecordIdOrBuilder
getAckIdsOrBuilder(int index)
repeated .hstream.server.RecordId ackIds = 3;
List<? extends RecordIdOrBuilder>
getAckIdsOrBuilderList()
repeated .hstream.server.RecordId ackIds = 3;
String
getConsumerName()
string consumerName = 2;
com.google.protobuf.ByteString
getConsumerNameBytes()
string consumerName = 2;
StreamingFetchRequest
getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor
getDescriptor()
com.google.protobuf.Descriptors.Descriptor
getDescriptorForType()
String
getSubscriptionId()
string subscriptionId = 1;
com.google.protobuf.ByteString
getSubscriptionIdBytes()
string subscriptionId = 1;
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable()
boolean
isInitialized()
StreamingFetchRequest.Builder
mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
StreamingFetchRequest.Builder
mergeFrom(com.google.protobuf.Message other)
StreamingFetchRequest.Builder
mergeFrom(StreamingFetchRequest other)
StreamingFetchRequest.Builder
mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
StreamingFetchRequest.Builder
removeAckIds(int index)
repeated .hstream.server.RecordId ackIds = 3;
StreamingFetchRequest.Builder
setAckIds(int index, RecordId value)
repeated .hstream.server.RecordId ackIds = 3;
StreamingFetchRequest.Builder
setAckIds(int index, RecordId.Builder builderForValue)
repeated .hstream.server.RecordId ackIds = 3;
StreamingFetchRequest.Builder
setConsumerName(String value)
string consumerName = 2;
StreamingFetchRequest.Builder
setConsumerNameBytes(com.google.protobuf.ByteString value)
string consumerName = 2;
StreamingFetchRequest.Builder
setSubscriptionId(String value)
string subscriptionId = 1;
StreamingFetchRequest.Builder
setSubscriptionIdBytes(com.google.protobuf.ByteString value)
string subscriptionId = 1;
StreamingFetchRequest.Builder
setUnknownFields(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:
internalGetFieldAccessorTable
in classcom.google.protobuf.GeneratedMessageV3.Builder<StreamingFetchRequest.Builder>
-
clear
public StreamingFetchRequest.Builder clear()
- Specified by:
clear
in interfacecom.google.protobuf.Message.Builder
- Specified by:
clear
in interfacecom.google.protobuf.MessageLite.Builder
- Overrides:
clear
in classcom.google.protobuf.GeneratedMessageV3.Builder<StreamingFetchRequest.Builder>
-
getDescriptorForType
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
- Specified by:
getDescriptorForType
in interfacecom.google.protobuf.Message.Builder
- Specified by:
getDescriptorForType
in interfacecom.google.protobuf.MessageOrBuilder
- Overrides:
getDescriptorForType
in classcom.google.protobuf.GeneratedMessageV3.Builder<StreamingFetchRequest.Builder>
-
getDefaultInstanceForType
public StreamingFetchRequest getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-
build
public StreamingFetchRequest build()
- Specified by:
build
in interfacecom.google.protobuf.Message.Builder
- Specified by:
build
in interfacecom.google.protobuf.MessageLite.Builder
-
buildPartial
public StreamingFetchRequest buildPartial()
- Specified by:
buildPartial
in interfacecom.google.protobuf.Message.Builder
- Specified by:
buildPartial
in interfacecom.google.protobuf.MessageLite.Builder
-
mergeFrom
public StreamingFetchRequest.Builder mergeFrom(com.google.protobuf.Message other)
- Specified by:
mergeFrom
in interfacecom.google.protobuf.Message.Builder
- Overrides:
mergeFrom
in classcom.google.protobuf.AbstractMessage.Builder<StreamingFetchRequest.Builder>
-
mergeFrom
public StreamingFetchRequest.Builder mergeFrom(StreamingFetchRequest other)
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in 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:
mergeFrom
in interfacecom.google.protobuf.Message.Builder
- Specified by:
mergeFrom
in interfacecom.google.protobuf.MessageLite.Builder
- Overrides:
mergeFrom
in classcom.google.protobuf.AbstractMessage.Builder<StreamingFetchRequest.Builder>
- Throws:
IOException
-
getSubscriptionId
public String getSubscriptionId()
string subscriptionId = 1;
- Specified by:
getSubscriptionId
in interfaceStreamingFetchRequestOrBuilder
- Returns:
- The subscriptionId.
-
getSubscriptionIdBytes
public com.google.protobuf.ByteString getSubscriptionIdBytes()
string subscriptionId = 1;
- Specified by:
getSubscriptionIdBytes
in 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:
getConsumerName
in interfaceStreamingFetchRequestOrBuilder
- Returns:
- The consumerName.
-
getConsumerNameBytes
public com.google.protobuf.ByteString getConsumerNameBytes()
string consumerName = 2;
- Specified by:
getConsumerNameBytes
in 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:
getAckIdsList
in interfaceStreamingFetchRequestOrBuilder
-
getAckIdsCount
public int getAckIdsCount()
repeated .hstream.server.RecordId ackIds = 3;
- Specified by:
getAckIdsCount
in interfaceStreamingFetchRequestOrBuilder
-
getAckIds
public RecordId getAckIds(int index)
repeated .hstream.server.RecordId ackIds = 3;
- Specified by:
getAckIds
in 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:
getAckIdsOrBuilder
in interfaceStreamingFetchRequestOrBuilder
-
getAckIdsOrBuilderList
public List<? extends RecordIdOrBuilder> getAckIdsOrBuilderList()
repeated .hstream.server.RecordId ackIds = 3;
- Specified by:
getAckIdsOrBuilderList
in 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:
setUnknownFields
in interfacecom.google.protobuf.Message.Builder
- Overrides:
setUnknownFields
in classcom.google.protobuf.GeneratedMessageV3.Builder<StreamingFetchRequest.Builder>
-
mergeUnknownFields
public final StreamingFetchRequest.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
- Specified by:
mergeUnknownFields
in interfacecom.google.protobuf.Message.Builder
- Overrides:
mergeUnknownFields
in classcom.google.protobuf.GeneratedMessageV3.Builder<StreamingFetchRequest.Builder>
-
-