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

Class ConcurrentAddressScopedStorage

java.lang.Object

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

All Implemented Interfaces:

AddressScopedStorage

@Internal
public final class ConcurrentAddressScopedStorage
extends java.lang.Object
implements AddressScopedStorage

Constructor Summary

Constructors

Constructor and Description
ConcurrentAddressScopedStorage(java.util.List<StateValueContexts.StateValueContext<?>> stateValues)

Method Summary

Modifier and Type	Method and Description
void	addMutations(java.util.function.Consumer<FromFunction.PersistedValueMutation> consumer)
<T> java.util.Optional<T>	get(ValueSpec<T> valueSpec) Gets the value of the provided ValueSpec, scoped to the current invoked Address.
<T> void	remove(ValueSpec<T> valueSpec) Removes the prior value set for the provided ValueSpec, scoped to the current invoked Address.
<T> void	set(ValueSpec<T> valueSpec, T value) Sets the value for the provided ValueSpec, scoped to the current invoked Address.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcurrentAddressScopedStorage

public ConcurrentAddressScopedStorage(java.util.List<StateValueContexts.StateValueContext<?>> stateValues)

Method Detail

get

public <T> java.util.Optional<T> get(ValueSpec<T> valueSpec)

Description copied from interface: AddressScopedStorage

Gets the value of the provided ValueSpec, scoped to the current invoked Address.

Specified by:

get in interface AddressScopedStorage

Type Parameters:

T - the type of the value.

Parameters:

valueSpec - the ValueSpec to read the value for.

Returns:

the value, or Optional.empty() if there was not prior value set.

set

public <T> void set(ValueSpec<T> valueSpec,
                    T value)

Description copied from interface: AddressScopedStorage

Sets the value for the provided ValueSpec, scoped to the current invoked Address.

Specified by:

set in interface AddressScopedStorage

Type Parameters:

T - the type of the value.

Parameters:

valueSpec - the ValueSpec to write the new value for.

value - the new value to set.

remove

public <T> void remove(ValueSpec<T> valueSpec)

Description copied from interface: AddressScopedStorage

Removes the prior value set for the provided ValueSpec, scoped to the current invoked Address.

After removing the value, calling AddressScopedStorage.get(ValueSpec) for the same spec will return an Optional.empty().

Specified by:

remove in interface AddressScopedStorage

Type Parameters:

T - the type of the value.

Parameters:

valueSpec - the ValueSpec to remove the prior value for.

addMutations

public void addMutations(java.util.function.Consumer<FromFunction.PersistedValueMutation> consumer)