Uses of Class
org.apache.flink.statefun.sdk.java.ValueSpec

Packages that use ValueSpec

Package	Description
org.apache.flink.statefun.e2e.smoke.java
org.apache.flink.statefun.sdk.java
org.apache.flink.statefun.sdk.java.storage

Uses of ValueSpec in org.apache.flink.statefun.e2e.smoke.java

Fields in org.apache.flink.statefun.e2e.smoke.java declared as ValueSpec

Modifier and Type	Field and Description
static ValueSpec<java.lang.Long>	CommandInterpreterFn.STATE

Methods in org.apache.flink.statefun.e2e.smoke.java with parameters of type ValueSpec

Modifier and Type	Method and Description
void	CommandInterpreter.interpret(ValueSpec<java.lang.Long> state, Context context, Message message)

Uses of ValueSpec in org.apache.flink.statefun.sdk.java

Methods in org.apache.flink.statefun.sdk.java that return ValueSpec

Modifier and Type	Method and Description
ValueSpec<java.lang.Boolean>	ValueSpec.Untyped.withBooleanType()
<T> ValueSpec<T>	ValueSpec.Untyped.withCustomType(Type<T> type)
ValueSpec<java.lang.Double>	ValueSpec.Untyped.withDoubleType()
ValueSpec<java.lang.Float>	ValueSpec.Untyped.withFloatType()
ValueSpec<java.lang.Integer>	ValueSpec.Untyped.withIntType()
ValueSpec<java.lang.Long>	ValueSpec.Untyped.withLongType()
ValueSpec<java.lang.String>	ValueSpec.Untyped.withUtf8StringType()

Methods in org.apache.flink.statefun.sdk.java that return types with arguments of type ValueSpec

Modifier and Type	Method and Description
java.util.Map<java.lang.String,ValueSpec<?>>	StatefulFunctionSpec.knownValues()

Methods in org.apache.flink.statefun.sdk.java with parameters of type ValueSpec

Modifier and Type	Method and Description
<T> java.util.Optional<T>	AddressScopedStorage.get(ValueSpec<T> spec) Gets the value of the provided ValueSpec, scoped to the current invoked Address.
<T> void	AddressScopedStorage.remove(ValueSpec<T> spec) Removes the prior value set for the provided ValueSpec, scoped to the current invoked Address.
<T> void	AddressScopedStorage.set(ValueSpec<T> spec, T value) Sets the value for the provided ValueSpec, scoped to the current invoked Address.
static ByteString	ApiExtension.stateNameByteString(ValueSpec<?> spec)
StatefulFunctionSpec.Builder	StatefulFunctionSpec.Builder.withValueSpec(ValueSpec<?> valueSpec) Registers a ValueSpec that will be used by this function.
StatefulFunctionSpec.Builder	StatefulFunctionSpec.Builder.withValueSpecs(ValueSpec<?>... valueSpecs) Registers multiple ValueSpecs that will be used by this function.

Uses of ValueSpec in org.apache.flink.statefun.sdk.java.storage

Methods in org.apache.flink.statefun.sdk.java.storage that return ValueSpec

Modifier and Type	Method and Description
ValueSpec<T>	StateValueContexts.StateValueContext.spec()

Methods in org.apache.flink.statefun.sdk.java.storage that return types with arguments of type ValueSpec

Modifier and Type	Method and Description
java.util.List<ValueSpec<?>>	StateValueContexts.ResolutionResult.missingValues()

Methods in org.apache.flink.statefun.sdk.java.storage with parameters of type ValueSpec

Modifier and Type	Method and Description
<T> java.util.Optional<T>	ConcurrentAddressScopedStorage.get(ValueSpec<T> valueSpec)
<T> void	ConcurrentAddressScopedStorage.remove(ValueSpec<T> valueSpec)
<T> void	ConcurrentAddressScopedStorage.set(ValueSpec<T> valueSpec, T value)

Method parameters in org.apache.flink.statefun.sdk.java.storage with type arguments of type ValueSpec

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.