CoordinatorStoreImpl (Flink : 2.0-SNAPSHOT API)

@ThreadSafe
 @Internal
public class CoordinatorStoreImpl
extends Object
implements CoordinatorStore

Basic implementation of CoordinatorStore.

Constructors
Constructor and Description
`CoordinatorStoreImpl()`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`<R> R`	`apply(Object key, Function<Object,R> consumer)`
`Object`	`compute(Object key, BiFunction<Object,Object,Object> mappingFunction)`
`Object`	`computeIfPresent(Object key, BiFunction<Object,Object,Object> remappingFunction)`
`boolean`	`containsKey(Object key)`
`Object`	`get(Object key)`
`Object`	`putIfAbsent(Object key, Object value)`

public Object putIfAbsent(Object key,
                          Object value)

public Object computeIfPresent(Object key,
                               BiFunction<Object,Object,Object> remappingFunction)

public Object compute(Object key,
                      BiFunction<Object,Object,Object> mappingFunction)

public <R> R apply(Object key,
                   Function<Object,R> consumer)

Back to Flink Website