Package | Description |
---|---|
org.apache.flink.statefun.sdk.java.storage | |
org.apache.flink.statefun.sdk.reqreply.generated |
Modifier and Type | Method and Description |
---|---|
ToFunction.PersistedValue |
StateValueContexts.StateValueContext.protocolValue() |
Modifier and Type | Method and Description |
---|---|
static StateValueContexts.ResolutionResult |
StateValueContexts.resolve(java.util.Map<java.lang.String,ValueSpec<?>> registeredSpecs,
java.util.List<ToFunction.PersistedValue> protocolProvidedValues)
Tries to resolve any registered states that are known to us by the
ValueSpec with the
states provided to us by the runtime. |
Modifier and Type | Method and Description |
---|---|
ToFunction.PersistedValue |
ToFunction.PersistedValue.Builder.build() |
ToFunction.PersistedValue |
ToFunction.PersistedValue.Builder.buildPartial() |
static ToFunction.PersistedValue |
ToFunction.PersistedValue.getDefaultInstance() |
ToFunction.PersistedValue |
ToFunction.PersistedValue.getDefaultInstanceForType() |
ToFunction.PersistedValue |
ToFunction.PersistedValue.Builder.getDefaultInstanceForType() |
ToFunction.PersistedValue |
ToFunction.InvocationBatchRequestOrBuilder.getState(int index)
A list of PersistedValues that were registered as a persisted state.
|
ToFunction.PersistedValue |
ToFunction.InvocationBatchRequest.getState(int index)
A list of PersistedValues that were registered as a persisted state.
|
ToFunction.PersistedValue |
ToFunction.InvocationBatchRequest.Builder.getState(int index)
A list of PersistedValues that were registered as a persisted state.
|
static ToFunction.PersistedValue |
ToFunction.PersistedValue.parseDelimitedFrom(java.io.InputStream input) |
static ToFunction.PersistedValue |
ToFunction.PersistedValue.parseDelimitedFrom(java.io.InputStream input,
ExtensionRegistryLite extensionRegistry) |
static ToFunction.PersistedValue |
ToFunction.PersistedValue.parseFrom(byte[] data) |
static ToFunction.PersistedValue |
ToFunction.PersistedValue.parseFrom(byte[] data,
ExtensionRegistryLite extensionRegistry) |
static ToFunction.PersistedValue |
ToFunction.PersistedValue.parseFrom(java.nio.ByteBuffer data) |
static ToFunction.PersistedValue |
ToFunction.PersistedValue.parseFrom(java.nio.ByteBuffer data,
ExtensionRegistryLite extensionRegistry) |
static ToFunction.PersistedValue |
ToFunction.PersistedValue.parseFrom(ByteString data) |
static ToFunction.PersistedValue |
ToFunction.PersistedValue.parseFrom(ByteString data,
ExtensionRegistryLite extensionRegistry) |
static ToFunction.PersistedValue |
ToFunction.PersistedValue.parseFrom(CodedInputStream input) |
static ToFunction.PersistedValue |
ToFunction.PersistedValue.parseFrom(CodedInputStream input,
ExtensionRegistryLite extensionRegistry) |
static ToFunction.PersistedValue |
ToFunction.PersistedValue.parseFrom(java.io.InputStream input) |
static ToFunction.PersistedValue |
ToFunction.PersistedValue.parseFrom(java.io.InputStream input,
ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
Parser<ToFunction.PersistedValue> |
ToFunction.PersistedValue.getParserForType() |
java.util.List<ToFunction.PersistedValue> |
ToFunction.InvocationBatchRequestOrBuilder.getStateList()
A list of PersistedValues that were registered as a persisted state.
|
java.util.List<ToFunction.PersistedValue> |
ToFunction.InvocationBatchRequest.getStateList()
A list of PersistedValues that were registered as a persisted state.
|
java.util.List<ToFunction.PersistedValue> |
ToFunction.InvocationBatchRequest.Builder.getStateList()
A list of PersistedValues that were registered as a persisted state.
|
static Parser<ToFunction.PersistedValue> |
ToFunction.PersistedValue.parser() |
Modifier and Type | Method and Description |
---|---|
ToFunction.InvocationBatchRequest.Builder |
ToFunction.InvocationBatchRequest.Builder.addState(int index,
ToFunction.PersistedValue value)
A list of PersistedValues that were registered as a persisted state.
|
ToFunction.InvocationBatchRequest.Builder |
ToFunction.InvocationBatchRequest.Builder.addState(ToFunction.PersistedValue value)
A list of PersistedValues that were registered as a persisted state.
|
ToFunction.PersistedValue.Builder |
ToFunction.PersistedValue.Builder.mergeFrom(ToFunction.PersistedValue other) |
static ToFunction.PersistedValue.Builder |
ToFunction.PersistedValue.newBuilder(ToFunction.PersistedValue prototype) |
ToFunction.InvocationBatchRequest.Builder |
ToFunction.InvocationBatchRequest.Builder.setState(int index,
ToFunction.PersistedValue value)
A list of PersistedValues that were registered as a persisted state.
|
Modifier and Type | Method and Description |
---|---|
ToFunction.InvocationBatchRequest.Builder |
ToFunction.InvocationBatchRequest.Builder.addAllState(java.lang.Iterable<? extends ToFunction.PersistedValue> values)
A list of PersistedValues that were registered as a persisted state.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.