public static final class Envelope.Builder extends com.google.protobuf.GeneratedMessageV3.Builder<Envelope.Builder> implements EnvelopeOrBuilder
org.apache.flink.statefun.flink.core.Envelope
Modifier and Type | Method and Description |
---|---|
Envelope.Builder |
addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
java.lang.Object value) |
Envelope |
build() |
Envelope |
buildPartial() |
Envelope.Builder |
clear() |
Envelope.Builder |
clearBody() |
Envelope.Builder |
clearCancellationToken()
an optional token that can be used track delayed message cancellation.
|
Envelope.Builder |
clearCheckpoint()
.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4; |
Envelope.Builder |
clearField(com.google.protobuf.Descriptors.FieldDescriptor field) |
Envelope.Builder |
clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) |
Envelope.Builder |
clearPayload()
.org.apache.flink.statefun.flink.core.Payload payload = 3; |
Envelope.Builder |
clearSource()
.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1; |
Envelope.Builder |
clearTarget()
.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2; |
Envelope.Builder |
clone() |
Envelope.BodyCase |
getBodyCase() |
java.lang.String |
getCancellationToken()
an optional token that can be used track delayed message cancellation.
|
com.google.protobuf.ByteString |
getCancellationTokenBytes()
an optional token that can be used track delayed message cancellation.
|
Checkpoint |
getCheckpoint()
.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4; |
Checkpoint.Builder |
getCheckpointBuilder()
.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4; |
CheckpointOrBuilder |
getCheckpointOrBuilder()
.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4; |
Envelope |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
com.google.protobuf.Descriptors.Descriptor |
getDescriptorForType() |
Payload |
getPayload()
.org.apache.flink.statefun.flink.core.Payload payload = 3; |
Payload.Builder |
getPayloadBuilder()
.org.apache.flink.statefun.flink.core.Payload payload = 3; |
PayloadOrBuilder |
getPayloadOrBuilder()
.org.apache.flink.statefun.flink.core.Payload payload = 3; |
EnvelopeAddress |
getSource()
.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1; |
EnvelopeAddress.Builder |
getSourceBuilder()
.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1; |
EnvelopeAddressOrBuilder |
getSourceOrBuilder()
.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1; |
EnvelopeAddress |
getTarget()
.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2; |
EnvelopeAddress.Builder |
getTargetBuilder()
.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2; |
EnvelopeAddressOrBuilder |
getTargetOrBuilder()
.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2; |
boolean |
hasCheckpoint()
.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4; |
boolean |
hasPayload()
.org.apache.flink.statefun.flink.core.Payload payload = 3; |
boolean |
hasSource()
.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1; |
boolean |
hasTarget()
.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2; |
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
Envelope.Builder |
mergeCheckpoint(Checkpoint value)
.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4; |
Envelope.Builder |
mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Envelope.Builder |
mergeFrom(Envelope other) |
Envelope.Builder |
mergeFrom(com.google.protobuf.Message other) |
Envelope.Builder |
mergePayload(Payload value)
.org.apache.flink.statefun.flink.core.Payload payload = 3; |
Envelope.Builder |
mergeSource(EnvelopeAddress value)
.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1; |
Envelope.Builder |
mergeTarget(EnvelopeAddress value)
.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2; |
Envelope.Builder |
mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
Envelope.Builder |
setCancellationToken(java.lang.String value)
an optional token that can be used track delayed message cancellation.
|
Envelope.Builder |
setCancellationTokenBytes(com.google.protobuf.ByteString value)
an optional token that can be used track delayed message cancellation.
|
Envelope.Builder |
setCheckpoint(Checkpoint.Builder builderForValue)
.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4; |
Envelope.Builder |
setCheckpoint(Checkpoint value)
.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4; |
Envelope.Builder |
setField(com.google.protobuf.Descriptors.FieldDescriptor field,
java.lang.Object value) |
Envelope.Builder |
setPayload(Payload.Builder builderForValue)
.org.apache.flink.statefun.flink.core.Payload payload = 3; |
Envelope.Builder |
setPayload(Payload value)
.org.apache.flink.statefun.flink.core.Payload payload = 3; |
Envelope.Builder |
setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
int index,
java.lang.Object value) |
Envelope.Builder |
setSource(EnvelopeAddress.Builder builderForValue)
.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1; |
Envelope.Builder |
setSource(EnvelopeAddress value)
.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1; |
Envelope.Builder |
setTarget(EnvelopeAddress.Builder builderForValue)
.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2; |
Envelope.Builder |
setTarget(EnvelopeAddress value)
.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2; |
Envelope.Builder |
setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, internalGetMapField, internalGetMutableMapField, isClean, markClean, newBuilderForField, onBuilt, onChanged, setUnknownFieldsProto3
findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toString
addAll, addAll, mergeFrom, newUninitializedMessageException
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable
in class com.google.protobuf.GeneratedMessageV3.Builder<Envelope.Builder>
public Envelope.Builder clear()
clear
in interface com.google.protobuf.Message.Builder
clear
in interface com.google.protobuf.MessageLite.Builder
clear
in class com.google.protobuf.GeneratedMessageV3.Builder<Envelope.Builder>
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
getDescriptorForType
in interface com.google.protobuf.Message.Builder
getDescriptorForType
in interface com.google.protobuf.MessageOrBuilder
getDescriptorForType
in class com.google.protobuf.GeneratedMessageV3.Builder<Envelope.Builder>
public Envelope getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder
public Envelope build()
build
in interface com.google.protobuf.Message.Builder
build
in interface com.google.protobuf.MessageLite.Builder
public Envelope buildPartial()
buildPartial
in interface com.google.protobuf.Message.Builder
buildPartial
in interface com.google.protobuf.MessageLite.Builder
public Envelope.Builder clone()
clone
in interface com.google.protobuf.Message.Builder
clone
in interface com.google.protobuf.MessageLite.Builder
clone
in class com.google.protobuf.GeneratedMessageV3.Builder<Envelope.Builder>
public Envelope.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value)
setField
in interface com.google.protobuf.Message.Builder
setField
in class com.google.protobuf.GeneratedMessageV3.Builder<Envelope.Builder>
public Envelope.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
clearField
in interface com.google.protobuf.Message.Builder
clearField
in class com.google.protobuf.GeneratedMessageV3.Builder<Envelope.Builder>
public Envelope.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
clearOneof
in interface com.google.protobuf.Message.Builder
clearOneof
in class com.google.protobuf.GeneratedMessageV3.Builder<Envelope.Builder>
public Envelope.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value)
setRepeatedField
in interface com.google.protobuf.Message.Builder
setRepeatedField
in class com.google.protobuf.GeneratedMessageV3.Builder<Envelope.Builder>
public Envelope.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value)
addRepeatedField
in interface com.google.protobuf.Message.Builder
addRepeatedField
in class com.google.protobuf.GeneratedMessageV3.Builder<Envelope.Builder>
public Envelope.Builder mergeFrom(com.google.protobuf.Message other)
mergeFrom
in interface com.google.protobuf.Message.Builder
mergeFrom
in class com.google.protobuf.AbstractMessage.Builder<Envelope.Builder>
public Envelope.Builder mergeFrom(Envelope other)
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLiteOrBuilder
isInitialized
in class com.google.protobuf.GeneratedMessageV3.Builder<Envelope.Builder>
public Envelope.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
mergeFrom
in interface com.google.protobuf.Message.Builder
mergeFrom
in interface com.google.protobuf.MessageLite.Builder
mergeFrom
in class com.google.protobuf.AbstractMessage.Builder<Envelope.Builder>
java.io.IOException
public Envelope.BodyCase getBodyCase()
getBodyCase
in interface EnvelopeOrBuilder
public Envelope.Builder clearBody()
public boolean hasSource()
.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1;
hasSource
in interface EnvelopeOrBuilder
public EnvelopeAddress getSource()
.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1;
getSource
in interface EnvelopeOrBuilder
public Envelope.Builder setSource(EnvelopeAddress value)
.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1;
public Envelope.Builder setSource(EnvelopeAddress.Builder builderForValue)
.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1;
public Envelope.Builder mergeSource(EnvelopeAddress value)
.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1;
public Envelope.Builder clearSource()
.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1;
public EnvelopeAddress.Builder getSourceBuilder()
.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1;
public EnvelopeAddressOrBuilder getSourceOrBuilder()
.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1;
getSourceOrBuilder
in interface EnvelopeOrBuilder
public boolean hasTarget()
.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2;
hasTarget
in interface EnvelopeOrBuilder
public EnvelopeAddress getTarget()
.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2;
getTarget
in interface EnvelopeOrBuilder
public Envelope.Builder setTarget(EnvelopeAddress value)
.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2;
public Envelope.Builder setTarget(EnvelopeAddress.Builder builderForValue)
.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2;
public Envelope.Builder mergeTarget(EnvelopeAddress value)
.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2;
public Envelope.Builder clearTarget()
.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2;
public EnvelopeAddress.Builder getTargetBuilder()
.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2;
public EnvelopeAddressOrBuilder getTargetOrBuilder()
.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2;
getTargetOrBuilder
in interface EnvelopeOrBuilder
public java.lang.String getCancellationToken()
an optional token that can be used track delayed message cancellation.
string cancellation_token = 10;
getCancellationToken
in interface EnvelopeOrBuilder
public com.google.protobuf.ByteString getCancellationTokenBytes()
an optional token that can be used track delayed message cancellation.
string cancellation_token = 10;
getCancellationTokenBytes
in interface EnvelopeOrBuilder
public Envelope.Builder setCancellationToken(java.lang.String value)
an optional token that can be used track delayed message cancellation.
string cancellation_token = 10;
public Envelope.Builder clearCancellationToken()
an optional token that can be used track delayed message cancellation.
string cancellation_token = 10;
public Envelope.Builder setCancellationTokenBytes(com.google.protobuf.ByteString value)
an optional token that can be used track delayed message cancellation.
string cancellation_token = 10;
public boolean hasCheckpoint()
.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4;
hasCheckpoint
in interface EnvelopeOrBuilder
public Checkpoint getCheckpoint()
.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4;
getCheckpoint
in interface EnvelopeOrBuilder
public Envelope.Builder setCheckpoint(Checkpoint value)
.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4;
public Envelope.Builder setCheckpoint(Checkpoint.Builder builderForValue)
.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4;
public Envelope.Builder mergeCheckpoint(Checkpoint value)
.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4;
public Envelope.Builder clearCheckpoint()
.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4;
public Checkpoint.Builder getCheckpointBuilder()
.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4;
public CheckpointOrBuilder getCheckpointOrBuilder()
.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4;
getCheckpointOrBuilder
in interface EnvelopeOrBuilder
public boolean hasPayload()
.org.apache.flink.statefun.flink.core.Payload payload = 3;
hasPayload
in interface EnvelopeOrBuilder
public Payload getPayload()
.org.apache.flink.statefun.flink.core.Payload payload = 3;
getPayload
in interface EnvelopeOrBuilder
public Envelope.Builder setPayload(Payload value)
.org.apache.flink.statefun.flink.core.Payload payload = 3;
public Envelope.Builder setPayload(Payload.Builder builderForValue)
.org.apache.flink.statefun.flink.core.Payload payload = 3;
public Envelope.Builder mergePayload(Payload value)
.org.apache.flink.statefun.flink.core.Payload payload = 3;
public Envelope.Builder clearPayload()
.org.apache.flink.statefun.flink.core.Payload payload = 3;
public Payload.Builder getPayloadBuilder()
.org.apache.flink.statefun.flink.core.Payload payload = 3;
public PayloadOrBuilder getPayloadOrBuilder()
.org.apache.flink.statefun.flink.core.Payload payload = 3;
getPayloadOrBuilder
in interface EnvelopeOrBuilder
public final Envelope.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
setUnknownFields
in interface com.google.protobuf.Message.Builder
setUnknownFields
in class com.google.protobuf.GeneratedMessageV3.Builder<Envelope.Builder>
public final Envelope.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
mergeUnknownFields
in interface com.google.protobuf.Message.Builder
mergeUnknownFields
in class com.google.protobuf.GeneratedMessageV3.Builder<Envelope.Builder>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.