Package | Description |
---|---|
org.apache.flink.api.common.state | |
org.apache.flink.queryablestate.client.state |
Modifier and Type | Method and Description |
---|---|
AggregatingState<IN,OUT> |
AggregatingStateDescriptor.bind(StateBinder stateBinder) |
ListState<T> |
ListStateDescriptor.bind(StateBinder stateBinder) |
abstract S |
StateDescriptor.bind(StateBinder stateBinder)
Creates a new
State on the given StateBinder . |
ValueState<T> |
ValueStateDescriptor.bind(StateBinder stateBinder) |
ReducingState<T> |
ReducingStateDescriptor.bind(StateBinder stateBinder) |
FoldingState<T,ACC> |
FoldingStateDescriptor.bind(StateBinder stateBinder)
Deprecated.
|
MapState<UK,UV> |
MapStateDescriptor.bind(StateBinder stateBinder) |
Modifier and Type | Class and Description |
---|---|
class |
ImmutableStateBinder
A
StateBinder used to deserialize the results returned by the
QueryableStateClient . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.