org.apache.flink.statefun.sdk.java.storage

Class StateValueContexts

java.lang.Object

org.apache.flink.statefun.sdk.java.storage.StateValueContexts

@Internal
public final class StateValueContexts
extends java.lang.Object

Utility for pairing registered ValueSpecs with values provided by the protocol's ToFunction message.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StateValueContexts.ResolutionResult
static class	StateValueContexts.StateValueContext<T>

Constructor Summary

Constructors

Constructor and Description
StateValueContexts()

Method Summary

Modifier and Type	Method and Description
static StateValueContexts.ResolutionResult	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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StateValueContexts

public StateValueContexts()

Method Detail

resolve

public static StateValueContexts.ResolutionResult 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.