Modifier and Type | Class and Description |
---|---|
static class |
KafkaProducerRecord.Builder
Protobuf type
io.statefun.sdk.egress.KafkaProducerRecord |
static class |
KinesisEgressRecord.Builder
Protobuf type
io.statefun.sdk.egress.KinesisEgressRecord |
Modifier and Type | Class and Description |
---|---|
static class |
Address.Builder
An Address is the unique identity of an individual StatefulFunction, containing
a function's type and an unique identifier within the type.
|
static class |
FromFunction.Builder
The following section contains messages sent from a remote function back to Flink.
|
static class |
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.
|
static class |
FromFunction.EgressMessage.Builder
EgressMessage an argument to forward to an egress.
|
static class |
FromFunction.ExpirationSpec.Builder
ExpirationSpec represents TTL (Time-To-Live) configuration for persisted states.
|
static class |
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.
|
static class |
FromFunction.Invocation.Builder
Invocation represents a remote function call, it associated with a (mandatory) target address,
and an argument.
|
static class |
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.
|
static class |
FromFunction.PersistedValueMutation.Builder
MutatePersistedValueCommand represents a command sent from a remote function to Flink,
requesting a change to a persisted value.
|
static class |
FromFunction.PersistedValueSpec.Builder
PersistedValueSpec represents specifications of a function's persisted value state.
|
static class |
ToFunction.Builder
The following section contains all the message types that are sent
from Flink to a remote function.
|
static class |
ToFunction.Invocation.Builder
Invocation represents a remote function call, it associated with an (optional) return address,
and an argument.
|
static class |
ToFunction.InvocationBatchRequest.Builder
InvocationBatchRequest represents a request to invoke a remote function.
|
static class |
ToFunction.PersistedValue.Builder
PersistedValue represents a PersistedValue's value that is managed by Flink on behalf of a remote function.
|
static class |
TypedValue.Builder
Protobuf type
io.statefun.sdk.reqreply.TypedValue |
Modifier and Type | Interface and Description |
---|---|
static interface |
Message.Builder
Abstract interface implemented by Protocol Message builders.
|
Modifier and Type | Class and Description |
---|---|
static class |
AbstractMessage.Builder<BuilderType extends AbstractMessage.Builder<BuilderType>>
A partial implementation of the
Message.Builder 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. |
static class |
Any.Builder
`Any` contains an arbitrary serialized protocol buffer message along with a
URL that describes the type of the serialized message.
|
static class |
Api.Builder
Api is a light-weight descriptor for an API Interface.
|
static class |
BoolValue.Builder
Wrapper message for `bool`.
|
static class |
BytesValue.Builder
Wrapper message for `bytes`.
|
static class |
DescriptorProtos.DescriptorProto.Builder
Describes a message type.
|
static class |
DescriptorProtos.DescriptorProto.ExtensionRange.Builder
Protobuf type
google.protobuf.DescriptorProto.ExtensionRange |
static class |
DescriptorProtos.DescriptorProto.ReservedRange.Builder
Range of reserved tag numbers.
|
static class |
DescriptorProtos.EnumDescriptorProto.Builder
Describes an enum type.
|
static class |
DescriptorProtos.EnumDescriptorProto.EnumReservedRange.Builder
Range of reserved numeric values.
|
static class |
DescriptorProtos.EnumOptions.Builder
Protobuf type
google.protobuf.EnumOptions |
static class |
DescriptorProtos.EnumValueDescriptorProto.Builder
Describes a value within an enum.
|
static class |
DescriptorProtos.EnumValueOptions.Builder
Protobuf type
google.protobuf.EnumValueOptions |
static class |
DescriptorProtos.ExtensionRangeOptions.Builder
Protobuf type
google.protobuf.ExtensionRangeOptions |
static class |
DescriptorProtos.FieldDescriptorProto.Builder
Describes a field within a message.
|
static class |
DescriptorProtos.FieldOptions.Builder
Protobuf type
google.protobuf.FieldOptions |
static class |
DescriptorProtos.FileDescriptorProto.Builder
Describes a complete .proto file.
|
static class |
DescriptorProtos.FileDescriptorSet.Builder
The protocol compiler can output a FileDescriptorSet containing the .proto
files it parses.
|
static class |
DescriptorProtos.FileOptions.Builder
Protobuf type
google.protobuf.FileOptions |
static class |
DescriptorProtos.GeneratedCodeInfo.Annotation.Builder
Protobuf type
google.protobuf.GeneratedCodeInfo.Annotation |
static class |
DescriptorProtos.GeneratedCodeInfo.Builder
Describes the relationship between generated code and its original source
file.
|
static class |
DescriptorProtos.MessageOptions.Builder
Protobuf type
google.protobuf.MessageOptions |
static class |
DescriptorProtos.MethodDescriptorProto.Builder
Describes a method of a service.
|
static class |
DescriptorProtos.MethodOptions.Builder
Protobuf type
google.protobuf.MethodOptions |
static class |
DescriptorProtos.OneofDescriptorProto.Builder
Describes a oneof.
|
static class |
DescriptorProtos.OneofOptions.Builder
Protobuf type
google.protobuf.OneofOptions |
static class |
DescriptorProtos.ServiceDescriptorProto.Builder
Describes a service.
|
static class |
DescriptorProtos.ServiceOptions.Builder
Protobuf type
google.protobuf.ServiceOptions |
static class |
DescriptorProtos.SourceCodeInfo.Builder
Encapsulates information about the original source file from which a
FileDescriptorProto was generated.
|
static class |
DescriptorProtos.SourceCodeInfo.Location.Builder
Protobuf type
google.protobuf.SourceCodeInfo.Location |
static class |
DescriptorProtos.UninterpretedOption.Builder
A message representing a option the parser does not recognize.
|
static class |
DescriptorProtos.UninterpretedOption.NamePart.Builder
The name of the uninterpreted option.
|
static class |
DoubleValue.Builder
Wrapper message for `double`.
|
static class |
Duration.Builder
A Duration represents a signed, fixed-length span of time represented
as a count of seconds and fractions of seconds at nanosecond
resolution.
|
static class |
DynamicMessage.Builder
Builder for
DynamicMessage s. |
static class |
Empty.Builder
A generic empty message that you can re-use to avoid defining duplicated
empty messages in your APIs.
|
static class |
Enum.Builder
Enum type definition.
|
static class |
EnumValue.Builder
Enum value definition.
|
static class |
Field.Builder
A single field of a message type.
|
static class |
FieldMask.Builder
`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`.
|
static class |
FloatValue.Builder
Wrapper message for `float`.
|
static class |
GeneratedMessage.Builder<BuilderType extends GeneratedMessage.Builder<BuilderType>> |
static class |
GeneratedMessage.ExtendableBuilder<MessageType extends GeneratedMessage.ExtendableMessage,BuilderType extends GeneratedMessage.ExtendableBuilder<MessageType,BuilderType>>
Generated message builders for message types that contain extension ranges
subclass this.
|
static class |
GeneratedMessageLite.Builder<MessageType extends GeneratedMessageLite<MessageType,BuilderType>,BuilderType extends GeneratedMessageLite.Builder<MessageType,BuilderType>> |
static class |
GeneratedMessageLite.ExtendableBuilder<MessageType extends GeneratedMessageLite.ExtendableMessage<MessageType,BuilderType>,BuilderType extends GeneratedMessageLite.ExtendableBuilder<MessageType,BuilderType>>
Lite equivalent of
GeneratedMessage.ExtendableBuilder . |
static class |
GeneratedMessageV3.Builder<BuilderType extends GeneratedMessageV3.Builder<BuilderType>> |
static class |
GeneratedMessageV3.ExtendableBuilder<MessageType extends GeneratedMessageV3.ExtendableMessage,BuilderType extends GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>
Generated message builders for message types that contain extension ranges
subclass this.
|
static class |
Int32Value.Builder
Wrapper message for `int32`.
|
static class |
Int64Value.Builder
Wrapper message for `int64`.
|
static class |
ListValue.Builder
`ListValue` is a wrapper around a repeated field of values.
|
static class |
MapEntry.Builder<K,V>
Builder to create
MapEntry messages. |
static class |
Method.Builder
Method represents a method of an API interface.
|
static class |
Mixin.Builder
Declares an API Interface to be included in this interface.
|
static class |
Option.Builder
A protocol buffer option, which can be attached to a message, field,
enumeration, etc.
|
static class |
SourceContext.Builder
`SourceContext` represents information about the source of a
protobuf element, like the file in which it is defined.
|
static class |
StringValue.Builder
Wrapper message for `string`.
|
static class |
Struct.Builder
`Struct` represents a structured data value, consisting of fields
which map to dynamically typed values.
|
static class |
Timestamp.Builder
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.
|
static class |
Type.Builder
A protocol buffer message type.
|
static class |
UInt32Value.Builder
Wrapper message for `uint32`.
|
static class |
UInt64Value.Builder
Wrapper message for `uint64`.
|
static class |
UnknownFieldSet.Builder
Builder for
UnknownFieldSet s. |
static class |
Value.Builder
`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 |
---|---|
MessageLite.Builder |
MessageLite.Builder.clear()
Resets all fields to their default values.
|
MessageLite.Builder |
MessageLite.Builder.clone()
Clones the Builder.
|
MessageLite.Builder |
Descriptors.FieldDescriptor.internalMergeFrom(MessageLite.Builder to,
MessageLite from)
For internal use only.
|
MessageLite.Builder |
MessageLite.Builder.mergeFrom(byte[] data)
Parse
data as a message of this type and merge it with the message being built. |
MessageLite.Builder |
MessageLite.Builder.mergeFrom(byte[] data,
ExtensionRegistryLite extensionRegistry)
Parse
data as a message of this type and merge it with the message being built. |
MessageLite.Builder |
MessageLite.Builder.mergeFrom(byte[] data,
int off,
int len)
Parse
data as a message of this type and merge it with the message being built. |
MessageLite.Builder |
MessageLite.Builder.mergeFrom(byte[] data,
int off,
int len,
ExtensionRegistryLite extensionRegistry)
Parse
data as a message of this type and merge it with the message being built. |
MessageLite.Builder |
MessageLite.Builder.mergeFrom(ByteString data)
Parse
data as a message of this type and merge it with the message being built. |
MessageLite.Builder |
MessageLite.Builder.mergeFrom(ByteString data,
ExtensionRegistryLite extensionRegistry)
Parse
data as a message of this type and merge it with the message being built. |
MessageLite.Builder |
MessageLite.Builder.mergeFrom(CodedInputStream input)
Parses a message of this type from the input and merges it with this message.
|
MessageLite.Builder |
MessageLite.Builder.mergeFrom(CodedInputStream input,
ExtensionRegistryLite extensionRegistry)
Like
mergeFrom(CodedInputStream) , but also parses extensions. |
MessageLite.Builder |
MessageLite.Builder.mergeFrom(java.io.InputStream input)
Parse a message of this type from
input and merge it with the message being built. |
MessageLite.Builder |
MessageLite.Builder.mergeFrom(java.io.InputStream input,
ExtensionRegistryLite extensionRegistry)
Parse a message of this type from
input and merge it with the message being built. |
MessageLite.Builder |
MessageLite.Builder.mergeFrom(MessageLite other)
Merge
other into the message being built. |
MessageLite.Builder |
MessageLite.newBuilderForType()
Constructs a new builder for a message of the same type as this message.
|
MessageLite.Builder |
MessageLite.toBuilder()
Constructs a builder initialized with the current message.
|
Modifier and Type | Method and Description |
---|---|
MessageLite.Builder |
Descriptors.FieldDescriptor.internalMergeFrom(MessageLite.Builder to,
MessageLite from)
For internal use only.
|
abstract void |
CodedInputStream.readGroup(int fieldNumber,
MessageLite.Builder builder,
ExtensionRegistryLite extensionRegistry)
Read a
group field value from the stream. |
abstract void |
CodedInputStream.readMessage(MessageLite.Builder builder,
ExtensionRegistryLite extensionRegistry)
Read an embedded message field value from the stream.
|
abstract void |
CodedInputStream.readUnknownGroup(int fieldNumber,
MessageLite.Builder builder)
Deprecated.
UnknownFieldSet.Builder now implements MessageLite.Builder, so you can just call
CodedInputStream.readGroup(int, org.apache.flink.statefun.sdk.shaded.com.google.protobuf.MessageLite.Builder, org.apache.flink.statefun.sdk.shaded.com.google.protobuf.ExtensionRegistryLite) . |
Modifier and Type | Class and Description |
---|---|
static class |
PluginProtos.CodeGeneratorRequest.Builder
An encoded CodeGeneratorRequest is written to the plugin's stdin.
|
static class |
PluginProtos.CodeGeneratorResponse.Builder
The plugin writes an encoded CodeGeneratorResponse to stdout.
|
static class |
PluginProtos.CodeGeneratorResponse.File.Builder
Represents a single generated file.
|
static class |
PluginProtos.Version.Builder
The version number of protocol compiler.
|
Modifier and Type | Class and Description |
---|---|
static class |
BooleanWrapper.Builder
BooleanWrapper represents a StateFun primitive type of a boolean value.
|
static class |
DoubleWrapper.Builder
DoubleWrapper represents a StateFun primitive type of a double value.
|
static class |
FloatWrapper.Builder
FloatWrapper represents a StateFun primitive type of a signed float value.
|
static class |
IntWrapper.Builder
IntWrapper represents a StateFun primitive type of an signed 32 bit integer value.
|
static class |
LongWrapper.Builder
LongWrapper represents a StateFun primitive type of a signed 64 bit long value.
|
static class |
StringWrapper.Builder
StringWrapper represents a StateFun string.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.