public final class FromFunction extends com.google.protobuf.GeneratedMessageV3 implements FromFunctionOrBuilder
The following section contains messages sent from a remote function back to Flink.Protobuf type
org.apache.flink.statefun.flink.core.polyglot.FromFunction
Modifier and Type | Class and Description |
---|---|
static class |
FromFunction.Builder
The following section contains messages sent from a remote function back to Flink.
|
static class |
FromFunction.DelayedInvocation
DelayedInvocation represents a delayed remote function call with a target address, an argument
and a delay in milliseconds, after which this message to be sent.
|
static interface |
FromFunction.DelayedInvocationOrBuilder |
static class |
FromFunction.EgressMessage
EgressMessage an argument to forward to an egress.
|
static interface |
FromFunction.EgressMessageOrBuilder |
static class |
FromFunction.Invocation
Invocation represents a remote function call, it associated with a (mandatory) target address,
and an argument.
|
static interface |
FromFunction.InvocationOrBuilder |
static class |
FromFunction.InvocationResponse
InvocationResponse represents a result of an org.apache.flink.statefun.flink.core.polyglot.ToFunction.InvocationBatchRequest
it contains a list of state mutation to preform as a result of computing this batch, and a list of outgoing messages.
|
static interface |
FromFunction.InvocationResponseOrBuilder |
static class |
FromFunction.PersistedValueMutation
MutatePersistedValueCommand represents a command sent from a remote function to Flink,
requesting a change to a persisted value.
|
static interface |
FromFunction.PersistedValueMutationOrBuilder |
static class |
FromFunction.ResponseCase |
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable, com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter
Modifier and Type | Field and Description |
---|---|
static int |
INVOCATION_RESULT_FIELD_NUMBER |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object obj) |
static FromFunction |
getDefaultInstance() |
FromFunction |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
FromFunction.InvocationResponse |
getInvocationResult()
.org.apache.flink.statefun.flink.core.polyglot.FromFunction.InvocationResponse invocation_result = 100; |
FromFunction.InvocationResponseOrBuilder |
getInvocationResultOrBuilder()
.org.apache.flink.statefun.flink.core.polyglot.FromFunction.InvocationResponse invocation_result = 100; |
com.google.protobuf.Parser<FromFunction> |
getParserForType() |
FromFunction.ResponseCase |
getResponseCase() |
int |
getSerializedSize() |
com.google.protobuf.UnknownFieldSet |
getUnknownFields() |
int |
hashCode() |
boolean |
hasInvocationResult()
.org.apache.flink.statefun.flink.core.polyglot.FromFunction.InvocationResponse invocation_result = 100; |
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
static FromFunction.Builder |
newBuilder() |
static FromFunction.Builder |
newBuilder(FromFunction prototype) |
FromFunction.Builder |
newBuilderForType() |
protected FromFunction.Builder |
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) |
static FromFunction |
parseDelimitedFrom(java.io.InputStream input) |
static FromFunction |
parseDelimitedFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FromFunction |
parseFrom(byte[] data) |
static FromFunction |
parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FromFunction |
parseFrom(java.nio.ByteBuffer data) |
static FromFunction |
parseFrom(java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FromFunction |
parseFrom(com.google.protobuf.ByteString data) |
static FromFunction |
parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FromFunction |
parseFrom(com.google.protobuf.CodedInputStream input) |
static FromFunction |
parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FromFunction |
parseFrom(java.io.InputStream input) |
static FromFunction |
parseFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static com.google.protobuf.Parser<FromFunction> |
parser() |
FromFunction.Builder |
toBuilder() |
void |
writeTo(com.google.protobuf.CodedOutputStream output) |
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof, internalGetMapField, makeExtensionsImmutable, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newInstance, newIntList, newLongList, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
addAll, addAll, checkByteStringIsUtf8, getSerializedSizeInternal, isInitializedInternal, makeImmutableInternal, mergeFromInternal, toByteArray, toByteString, writeDelimitedTo, writeTo, writeToInternal
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public static final int INVOCATION_RESULT_FIELD_NUMBER
public final com.google.protobuf.UnknownFieldSet getUnknownFields()
getUnknownFields
in interface com.google.protobuf.MessageOrBuilder
getUnknownFields
in class com.google.protobuf.GeneratedMessageV3
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable
in class com.google.protobuf.GeneratedMessageV3
public FromFunction.ResponseCase getResponseCase()
getResponseCase
in interface FromFunctionOrBuilder
public boolean hasInvocationResult()
.org.apache.flink.statefun.flink.core.polyglot.FromFunction.InvocationResponse invocation_result = 100;
hasInvocationResult
in interface FromFunctionOrBuilder
public FromFunction.InvocationResponse getInvocationResult()
.org.apache.flink.statefun.flink.core.polyglot.FromFunction.InvocationResponse invocation_result = 100;
getInvocationResult
in interface FromFunctionOrBuilder
public FromFunction.InvocationResponseOrBuilder getInvocationResultOrBuilder()
.org.apache.flink.statefun.flink.core.polyglot.FromFunction.InvocationResponse invocation_result = 100;
getInvocationResultOrBuilder
in interface FromFunctionOrBuilder
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLiteOrBuilder
isInitialized
in class com.google.protobuf.GeneratedMessageV3
public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException
writeTo
in interface com.google.protobuf.MessageLite
writeTo
in class com.google.protobuf.GeneratedMessageV3
java.io.IOException
public int getSerializedSize()
getSerializedSize
in interface com.google.protobuf.MessageLite
getSerializedSize
in class com.google.protobuf.GeneratedMessageV3
public boolean equals(java.lang.Object obj)
equals
in interface com.google.protobuf.Message
equals
in class com.google.protobuf.AbstractMessage
public int hashCode()
hashCode
in interface com.google.protobuf.Message
hashCode
in class com.google.protobuf.AbstractMessage
public static FromFunction parseFrom(java.nio.ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FromFunction parseFrom(java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FromFunction parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FromFunction parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FromFunction parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FromFunction parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static FromFunction parseFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOException
public static FromFunction parseFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public static FromFunction parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOException
public static FromFunction parseDelimitedFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public static FromFunction parseFrom(com.google.protobuf.CodedInputStream input) throws java.io.IOException
java.io.IOException
public static FromFunction parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public FromFunction.Builder newBuilderForType()
newBuilderForType
in interface com.google.protobuf.Message
newBuilderForType
in interface com.google.protobuf.MessageLite
public static FromFunction.Builder newBuilder()
public static FromFunction.Builder newBuilder(FromFunction prototype)
public FromFunction.Builder toBuilder()
toBuilder
in interface com.google.protobuf.Message
toBuilder
in interface com.google.protobuf.MessageLite
protected FromFunction.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
newBuilderForType
in class com.google.protobuf.GeneratedMessageV3
public static FromFunction getDefaultInstance()
public static com.google.protobuf.Parser<FromFunction> parser()
public com.google.protobuf.Parser<FromFunction> getParserForType()
getParserForType
in interface com.google.protobuf.Message
getParserForType
in interface com.google.protobuf.MessageLite
getParserForType
in class com.google.protobuf.GeneratedMessageV3
public FromFunction getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.