Class and Description |
---|
Address
An Address is the unique identity of an individual StatefulFunction, containing
a function's type and an unique identifier within the type.
|
Class and Description |
---|
Address
An Address is the unique identity of an individual StatefulFunction, containing
a function's type and an unique identifier within the type.
|
Address.Builder
An Address is the unique identity of an individual StatefulFunction, containing
a function's type and an unique identifier within the type.
|
AddressOrBuilder |
FromFunction
The following section contains messages sent from a remote function back to Flink.
|
FromFunction.Builder
The following section contains messages sent from a remote function back to Flink.
|
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.
|
FromFunction.DelayedInvocation.Builder
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.
|
FromFunction.DelayedInvocationOrBuilder |
FromFunction.EgressMessage
EgressMessage an argument to forward to an egress.
|
FromFunction.EgressMessage.Builder
EgressMessage an argument to forward to an egress.
|
FromFunction.EgressMessageOrBuilder |
FromFunction.Invocation
Invocation represents a remote function call, it associated with a (mandatory) target address,
and an argument.
|
FromFunction.Invocation.Builder
Invocation represents a remote function call, it associated with a (mandatory) target address,
and an argument.
|
FromFunction.InvocationOrBuilder |
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.
|
FromFunction.InvocationResponse.Builder
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.
|
FromFunction.InvocationResponseOrBuilder |
FromFunction.PersistedValueMutation
MutatePersistedValueCommand represents a command sent from a remote function to Flink,
requesting a change to a persisted value.
|
FromFunction.PersistedValueMutation.Builder
MutatePersistedValueCommand represents a command sent from a remote function to Flink,
requesting a change to a persisted value.
|
FromFunction.PersistedValueMutation.MutationType
Protobuf enum
org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation.MutationType |
FromFunction.PersistedValueMutationOrBuilder |
FromFunction.ResponseCase |
FromFunctionOrBuilder |
ToFunction
The following section contains all the message types that are sent
from Flink to a remote function.
|
ToFunction.Builder
The following section contains all the message types that are sent
from Flink to a remote function.
|
ToFunction.Invocation
Invocation represents a remote function call, it associated with an (optional) return address,
and an argument.
|
ToFunction.Invocation.Builder
Invocation represents a remote function call, it associated with an (optional) return address,
and an argument.
|
ToFunction.InvocationBatchRequest
InvocationBatchRequest represents a request to invoke a remote function.
|
ToFunction.InvocationBatchRequest.Builder
InvocationBatchRequest represents a request to invoke a remote function.
|
ToFunction.InvocationBatchRequestOrBuilder |
ToFunction.InvocationOrBuilder |
ToFunction.PersistedValue
PersistedValue represents a PersistedValue's value that is managed by Flink on behalf of a remote function.
|
ToFunction.PersistedValue.Builder
PersistedValue represents a PersistedValue's value that is managed by Flink on behalf of a remote function.
|
ToFunction.PersistedValueOrBuilder |
ToFunction.RequestCase |
ToFunctionOrBuilder |
Class and Description |
---|
FromFunction
The following section contains messages sent from a remote function back to Flink.
|
ToFunction
The following section contains all the message types that are sent
from Flink to a remote function.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.