Modifier and Type | Class and Description |
---|---|
class |
KafkaProducerRecord
Protobuf type
io.statefun.sdk.egress.KafkaProducerRecord |
class |
KinesisEgressRecord
Protobuf type
io.statefun.sdk.egress.KinesisEgressRecord |
Modifier and Type | Class and Description |
---|---|
class |
Address
An Address is the unique identity of an individual StatefulFunction, containing
a function's type and an unique identifier within the type.
|
class |
FromFunction
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 class |
FromFunction.EgressMessage
EgressMessage an argument to forward to an egress.
|
static class |
FromFunction.ExpirationSpec
ExpirationSpec represents TTL (Time-To-Live) configuration for persisted states.
|
static class |
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.
|
static class |
FromFunction.Invocation
Invocation represents a remote function call, it associated with a (mandatory) target address,
and an argument.
|
static class |
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.
|
static class |
FromFunction.PersistedValueMutation
MutatePersistedValueCommand represents a command sent from a remote function to Flink,
requesting a change to a persisted value.
|
static class |
FromFunction.PersistedValueSpec
PersistedValueSpec represents specifications of a function's persisted value state.
|
class |
ToFunction
The following section contains all the message types that are sent
from Flink to a remote function.
|
static class |
ToFunction.Invocation
Invocation represents a remote function call, it associated with an (optional) return address,
and an argument.
|
static class |
ToFunction.InvocationBatchRequest
InvocationBatchRequest represents a request to invoke a remote function.
|
static class |
ToFunction.PersistedValue
PersistedValue represents a PersistedValue's value that is managed by Flink on behalf of a remote function.
|
class |
TypedValue
Protobuf type
io.statefun.sdk.reqreply.TypedValue |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMessageLite<MessageType extends AbstractMessageLite<MessageType,BuilderType>,BuilderType extends AbstractMessageLite.Builder<MessageType,BuilderType>>
A partial implementation of the
MessageLite interface which implements as many methods of
that interface as possible in terms of other methods. |
static class |
AbstractMessageLite.Builder<MessageType extends AbstractMessageLite<MessageType,BuilderType>,BuilderType extends AbstractMessageLite.Builder<MessageType,BuilderType>>
A partial implementation of the
Message.Builder interface which implements as many
methods of that interface as possible in terms of other methods. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMessage
A partial implementation of the
Message interface which implements as many methods of
that interface as possible in terms of other methods. |
class |
Any
`Any` contains an arbitrary serialized protocol buffer message along with a
URL that describes the type of the serialized message.
|
class |
Api
Api is a light-weight descriptor for an API Interface.
|
class |
BoolValue
Wrapper message for `bool`.
|
class |
BytesValue
Wrapper message for `bytes`.
|
static class |
DescriptorProtos.DescriptorProto
Describes a message type.
|
static class |
DescriptorProtos.DescriptorProto.ExtensionRange
Protobuf type
google.protobuf.DescriptorProto.ExtensionRange |
static class |
DescriptorProtos.DescriptorProto.ReservedRange
Range of reserved tag numbers.
|
static class |
DescriptorProtos.EnumDescriptorProto
Describes an enum type.
|
static class |
DescriptorProtos.EnumDescriptorProto.EnumReservedRange
Range of reserved numeric values.
|
static class |
DescriptorProtos.EnumOptions
Protobuf type
google.protobuf.EnumOptions |
static class |
DescriptorProtos.EnumValueDescriptorProto
Describes a value within an enum.
|
static class |
DescriptorProtos.EnumValueOptions
Protobuf type
google.protobuf.EnumValueOptions |
static class |
DescriptorProtos.ExtensionRangeOptions
Protobuf type
google.protobuf.ExtensionRangeOptions |
static class |
DescriptorProtos.FieldDescriptorProto
Describes a field within a message.
|
static class |
DescriptorProtos.FieldOptions
Protobuf type
google.protobuf.FieldOptions |
static class |
DescriptorProtos.FileDescriptorProto
Describes a complete .proto file.
|
static class |
DescriptorProtos.FileDescriptorSet
The protocol compiler can output a FileDescriptorSet containing the .proto
files it parses.
|
static class |
DescriptorProtos.FileOptions
Protobuf type
google.protobuf.FileOptions |
static class |
DescriptorProtos.GeneratedCodeInfo
Describes the relationship between generated code and its original source
file.
|
static class |
DescriptorProtos.GeneratedCodeInfo.Annotation
Protobuf type
google.protobuf.GeneratedCodeInfo.Annotation |
static class |
DescriptorProtos.MessageOptions
Protobuf type
google.protobuf.MessageOptions |
static class |
DescriptorProtos.MethodDescriptorProto
Describes a method of a service.
|
static class |
DescriptorProtos.MethodOptions
Protobuf type
google.protobuf.MethodOptions |
static class |
DescriptorProtos.OneofDescriptorProto
Describes a oneof.
|
static class |
DescriptorProtos.OneofOptions
Protobuf type
google.protobuf.OneofOptions |
static class |
DescriptorProtos.ServiceDescriptorProto
Describes a service.
|
static class |
DescriptorProtos.ServiceOptions
Protobuf type
google.protobuf.ServiceOptions |
static class |
DescriptorProtos.SourceCodeInfo
Encapsulates information about the original source file from which a
FileDescriptorProto was generated.
|
static class |
DescriptorProtos.SourceCodeInfo.Location
Protobuf type
google.protobuf.SourceCodeInfo.Location |
static class |
DescriptorProtos.UninterpretedOption
A message representing a option the parser does not recognize.
|
static class |
DescriptorProtos.UninterpretedOption.NamePart
The name of the uninterpreted option.
|
class |
DoubleValue
Wrapper message for `double`.
|
class |
Duration
A Duration represents a signed, fixed-length span of time represented
as a count of seconds and fractions of seconds at nanosecond
resolution.
|
class |
DynamicMessage
An implementation of
Message that can represent arbitrary types, given a Descriptors.Descriptor . |
class |
Empty
A generic empty message that you can re-use to avoid defining duplicated
empty messages in your APIs.
|
class |
Enum
Enum type definition.
|
class |
EnumValue
Enum value definition.
|
class |
Field
A single field of a message type.
|
class |
FieldMask
`FieldMask` represents a set of symbolic field paths, for example:
paths: "f.a"
paths: "f.b.d"
Here `f` represents a field in some root message, `a` and `b`
fields in the message found in `f`, and `d` a field found in the
message in `f.b`.
|
class |
FloatValue
Wrapper message for `float`.
|
class |
GeneratedMessage
All generated protocol message classes extend this class.
|
static class |
GeneratedMessage.ExtendableMessage<MessageType extends GeneratedMessage.ExtendableMessage>
Generated message classes for message types that contain extension ranges
subclass this.
|
class |
GeneratedMessageLite<MessageType extends GeneratedMessageLite<MessageType,BuilderType>,BuilderType extends GeneratedMessageLite.Builder<MessageType,BuilderType>>
Lite version of
GeneratedMessage . |
static class |
GeneratedMessageLite.ExtendableMessage<MessageType extends GeneratedMessageLite.ExtendableMessage<MessageType,BuilderType>,BuilderType extends GeneratedMessageLite.ExtendableBuilder<MessageType,BuilderType>>
Lite equivalent of
GeneratedMessage.ExtendableMessage . |
class |
GeneratedMessageV3
All generated protocol message classes extend this class.
|
static class |
GeneratedMessageV3.ExtendableMessage<MessageType extends GeneratedMessageV3.ExtendableMessage>
Generated message classes for message types that contain extension ranges
subclass this.
|
class |
Int32Value
Wrapper message for `int32`.
|
class |
Int64Value
Wrapper message for `int64`.
|
class |
ListValue
`ListValue` is a wrapper around a repeated field of values.
|
class |
MapEntry<K,V>
Implements MapEntry messages.
|
class |
Method
Method represents a method of an API interface.
|
class |
Mixin
Declares an API Interface to be included in this interface.
|
class |
Option
A protocol buffer option, which can be attached to a message, field,
enumeration, etc.
|
class |
SourceContext
`SourceContext` represents information about the source of a
protobuf element, like the file in which it is defined.
|
class |
StringValue
Wrapper message for `string`.
|
class |
Struct
`Struct` represents a structured data value, consisting of fields
which map to dynamically typed values.
|
class |
Timestamp
A Timestamp represents a point in time independent of any time zone or local
calendar, encoded as a count of seconds and fractions of seconds at
nanosecond resolution.
|
class |
Type
A protocol buffer message type.
|
class |
UInt32Value
Wrapper message for `uint32`.
|
class |
UInt64Value
Wrapper message for `uint64`.
|
class |
Value
`Value` represents a dynamically typed value which can be either
null, a number, a string, a boolean, a recursive struct value, or a
list of values.
|
Modifier and Type | Method and Description |
---|---|
protected BuilderType |
AbstractMessage.Builder.internalMergeFrom(AbstractMessageLite other) |
Modifier and Type | Class and Description |
---|---|
static class |
PluginProtos.CodeGeneratorRequest
An encoded CodeGeneratorRequest is written to the plugin's stdin.
|
static class |
PluginProtos.CodeGeneratorResponse
The plugin writes an encoded CodeGeneratorResponse to stdout.
|
static class |
PluginProtos.CodeGeneratorResponse.File
Represents a single generated file.
|
static class |
PluginProtos.Version
The version number of protocol compiler.
|
Modifier and Type | Class and Description |
---|---|
class |
BooleanWrapper
BooleanWrapper represents a StateFun primitive type of a boolean value.
|
class |
DoubleWrapper
DoubleWrapper represents a StateFun primitive type of a double value.
|
class |
FloatWrapper
FloatWrapper represents a StateFun primitive type of a signed float value.
|
class |
IntWrapper
IntWrapper represents a StateFun primitive type of an signed 32 bit integer value.
|
class |
LongWrapper
LongWrapper represents a StateFun primitive type of a signed 64 bit long value.
|
class |
StringWrapper
StringWrapper represents a StateFun string.
|
Copyright © 2014–2025 The Apache Software Foundation. All rights reserved.