Uses of Package
org.apache.flink.statefun.sdk.reqreply.generated

Packages that use org.apache.flink.statefun.sdk.reqreply.generated

Package	Description
org.apache.flink.statefun.e2e.smoke.driver
org.apache.flink.statefun.flink.common.types
org.apache.flink.statefun.flink.core.common
org.apache.flink.statefun.flink.core.reqreply
org.apache.flink.statefun.flink.io.common.json
org.apache.flink.statefun.flink.io.kafka.binders.egress.v1
org.apache.flink.statefun.flink.io.kinesis.binders.egress.v1
org.apache.flink.statefun.sdk.java.message
org.apache.flink.statefun.sdk.java.storage
org.apache.flink.statefun.sdk.reqreply.generated

Classes in org.apache.flink.statefun.sdk.reqreply.generated used by org.apache.flink.statefun.e2e.smoke.driver

Class and Description
TypedValue Protobuf type io.statefun.sdk.reqreply.TypedValue

Classes in org.apache.flink.statefun.sdk.reqreply.generated used by org.apache.flink.statefun.flink.common.types

Class and Description
TypedValue Protobuf type io.statefun.sdk.reqreply.TypedValue

Classes in org.apache.flink.statefun.sdk.reqreply.generated used by org.apache.flink.statefun.flink.core.common

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.

Classes in org.apache.flink.statefun.sdk.reqreply.generated used by org.apache.flink.statefun.flink.core.reqreply

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.

Classes in org.apache.flink.statefun.sdk.reqreply.generated used by org.apache.flink.statefun.flink.io.common.json

Class and Description
TypedValue Protobuf type io.statefun.sdk.reqreply.TypedValue

Classes in org.apache.flink.statefun.sdk.reqreply.generated used by org.apache.flink.statefun.flink.io.kafka.binders.egress.v1

Class and Description
TypedValue Protobuf type io.statefun.sdk.reqreply.TypedValue

Classes in org.apache.flink.statefun.sdk.reqreply.generated used by org.apache.flink.statefun.flink.io.kinesis.binders.egress.v1

Class and Description
TypedValue Protobuf type io.statefun.sdk.reqreply.TypedValue

Classes in org.apache.flink.statefun.sdk.reqreply.generated used by org.apache.flink.statefun.sdk.java.message

Class and Description
TypedValue Protobuf type io.statefun.sdk.reqreply.TypedValue

Classes in org.apache.flink.statefun.sdk.reqreply.generated used by org.apache.flink.statefun.sdk.java.storage

Class and Description
FromFunction.PersistedValueMutation MutatePersistedValueCommand represents a command sent from a remote function to Flink, requesting a change to a persisted value.
ToFunction.PersistedValue PersistedValue represents a PersistedValue's value that is managed by Flink on behalf of a remote function.

Classes in org.apache.flink.statefun.sdk.reqreply.generated used by org.apache.flink.statefun.sdk.reqreply.generated

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.ExpirationSpec ExpirationSpec represents TTL (Time-To-Live) configuration for persisted states.
FromFunction.ExpirationSpec.Builder ExpirationSpec represents TTL (Time-To-Live) configuration for persisted states.
FromFunction.ExpirationSpec.ExpireMode Protobuf enum io.statefun.sdk.reqreply.FromFunction.ExpirationSpec.ExpireMode
FromFunction.ExpirationSpecOrBuilder
FromFunction.IncompleteInvocationContext IncompleteInvocationContext represents a result of an io.statefun.sdk.reqreply.ToFunction.InvocationBatchRequest, which should be used as the response if the InvocationBatchRequest provided incomplete information about the invocation, e.g.
FromFunction.IncompleteInvocationContext.Builder IncompleteInvocationContext represents a result of an io.statefun.sdk.reqreply.ToFunction.InvocationBatchRequest, which should be used as the response if the InvocationBatchRequest provided incomplete information about the invocation, e.g.
FromFunction.IncompleteInvocationContextOrBuilder
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 io.statefun.sdk.reqreply.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 io.statefun.sdk.reqreply.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 io.statefun.sdk.reqreply.FromFunction.PersistedValueMutation.MutationType
FromFunction.PersistedValueMutationOrBuilder
FromFunction.PersistedValueSpec PersistedValueSpec represents specifications of a function's persisted value state.
FromFunction.PersistedValueSpec.Builder PersistedValueSpec represents specifications of a function's persisted value state.
FromFunction.PersistedValueSpecOrBuilder
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
TypedValue Protobuf type io.statefun.sdk.reqreply.TypedValue
TypedValue.Builder Protobuf type io.statefun.sdk.reqreply.TypedValue
TypedValueOrBuilder