org.apache.flink.statefun.flink.core.generated

Interface EnvelopeOrBuilder

All Superinterfaces:

com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder

All Known Implementing Classes:

Envelope, Envelope.Builder

public interface EnvelopeOrBuilder
extends com.google.protobuf.MessageOrBuilder

Method Summary

Modifier and Type	Method and Description
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;
CheckpointOrBuilder	getCheckpointOrBuilder() .org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4;
Payload	getPayload() .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;
EnvelopeAddressOrBuilder	getSourceOrBuilder() .org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1;
EnvelopeAddress	getTarget() .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;

Methods inherited from interface com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Methods inherited from interface com.google.protobuf.MessageLiteOrBuilder

isInitialized

Method Detail

hasSource

boolean hasSource()

.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1;

getSource

EnvelopeAddress getSource()

.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1;

getSourceOrBuilder

EnvelopeAddressOrBuilder getSourceOrBuilder()

.org.apache.flink.statefun.flink.core.EnvelopeAddress source = 1;

hasTarget

boolean hasTarget()

.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2;

getTarget

EnvelopeAddress getTarget()

.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2;

getTargetOrBuilder

EnvelopeAddressOrBuilder getTargetOrBuilder()

.org.apache.flink.statefun.flink.core.EnvelopeAddress target = 2;

getCancellationToken

java.lang.String getCancellationToken()

 an optional token that can be used track delayed message cancellation.
 

string cancellation_token = 10;

getCancellationTokenBytes

com.google.protobuf.ByteString getCancellationTokenBytes()

 an optional token that can be used track delayed message cancellation.
 

string cancellation_token = 10;

hasCheckpoint

boolean hasCheckpoint()

.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4;

getCheckpoint

Checkpoint getCheckpoint()

.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4;

getCheckpointOrBuilder

CheckpointOrBuilder getCheckpointOrBuilder()

.org.apache.flink.statefun.flink.core.Checkpoint checkpoint = 4;

hasPayload

boolean hasPayload()

.org.apache.flink.statefun.flink.core.Payload payload = 3;

getPayload

Payload getPayload()

.org.apache.flink.statefun.flink.core.Payload payload = 3;

getPayloadOrBuilder

PayloadOrBuilder getPayloadOrBuilder()

.org.apache.flink.statefun.flink.core.Payload payload = 3;

getBodyCase

Envelope.BodyCase getBodyCase()