public final class PartitionAssignmentAck extends GeneratedMessageV3 implements PartitionAssignmentAckOrBuilder
Acknowledge receipt and handling of the previous assignment.
If not sent within a short period after receiving the assignment,
partitions may remain unassigned for a period of time until the
client is known to be inactive, after which time the server will break the
stream.
Protobuf type google.cloud.pubsublite.v1.PartitionAssignmentAck
Inherited Members
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT)
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT,int)
com.google.protobuf.GeneratedMessageV3.<T>emptyList(java.lang.Class<T>)
com.google.protobuf.GeneratedMessageV3.internalGetMapFieldReflection(int)
Static Methods
getDefaultInstance()
public static PartitionAssignmentAck getDefaultInstance()
getDescriptor()
public static final Descriptors.Descriptor getDescriptor()
newBuilder()
public static PartitionAssignmentAck.Builder newBuilder()
newBuilder(PartitionAssignmentAck prototype)
public static PartitionAssignmentAck.Builder newBuilder(PartitionAssignmentAck prototype)
public static PartitionAssignmentAck parseDelimitedFrom(InputStream input)
public static PartitionAssignmentAck parseDelimitedFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
parseFrom(byte[] data)
public static PartitionAssignmentAck parseFrom(byte[] data)
Parameter |
---|
Name | Description |
data | byte[]
|
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static PartitionAssignmentAck parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
parseFrom(ByteString data)
public static PartitionAssignmentAck parseFrom(ByteString data)
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static PartitionAssignmentAck parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static PartitionAssignmentAck parseFrom(CodedInputStream input)
public static PartitionAssignmentAck parseFrom(CodedInputStream input, ExtensionRegistryLite extensionRegistry)
public static PartitionAssignmentAck parseFrom(InputStream input)
public static PartitionAssignmentAck parseFrom(InputStream input, ExtensionRegistryLite extensionRegistry)
parseFrom(ByteBuffer data)
public static PartitionAssignmentAck parseFrom(ByteBuffer data)
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static PartitionAssignmentAck parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
parser()
public static Parser<PartitionAssignmentAck> parser()
Methods
equals(Object obj)
public boolean equals(Object obj)
Parameter |
---|
Name | Description |
obj | Object
|
Overrides
getDefaultInstanceForType()
public PartitionAssignmentAck getDefaultInstanceForType()
getParserForType()
public Parser<PartitionAssignmentAck> getParserForType()
Overrides
getSerializedSize()
public int getSerializedSize()
Returns |
---|
Type | Description |
int | |
Overrides
hashCode()
Returns |
---|
Type | Description |
int | |
Overrides
internalGetFieldAccessorTable()
protected GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
Overrides
isInitialized()
public final boolean isInitialized()
Overrides
newBuilderForType()
public PartitionAssignmentAck.Builder newBuilderForType()
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected PartitionAssignmentAck.Builder newBuilderForType(GeneratedMessageV3.BuilderParent parent)
Overrides
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
Overrides
toBuilder()
public PartitionAssignmentAck.Builder toBuilder()
writeTo(CodedOutputStream output)
public void writeTo(CodedOutputStream output)
Overrides