org.apache.flink.streaming.runtime.operators.windowing

Class WindowOperator.PerWindowStateStore

java.lang.Object

org.apache.flink.runtime.state.DefaultKeyedStateStore

org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.AbstractPerWindowStateStore

org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.PerWindowStateStore

All Implemented Interfaces:

KeyedStateStore

Enclosing class:

WindowOperator<K,IN,ACC,OUT,W extends Window>

public class WindowOperator.PerWindowStateStore
extends WindowOperator.AbstractPerWindowStateStore

Regular per-window state store for use with ProcessWindowFunction.

Field Summary

Fields inherited from class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.AbstractPerWindowStateStore

window

Fields inherited from class org.apache.flink.runtime.state.DefaultKeyedStateStore

executionConfig, keyedStateBackend

Constructor Summary

Constructors

Constructor and Description
PerWindowStateStore(KeyedStateBackend<?> keyedStateBackend, ExecutionConfig executionConfig)

Method Summary

Modifier and Type	Method and Description
protected <S extends State> S	getPartitionedState(StateDescriptor<S,?> stateDescriptor)

Methods inherited from class org.apache.flink.runtime.state.DefaultKeyedStateStore

getAggregatingState, getListState, getMapState, getReducingState, getState

Methods inherited from class java.lang.Object

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

Constructor Detail

PerWindowStateStore

public PerWindowStateStore(KeyedStateBackend<?> keyedStateBackend,
                           ExecutionConfig executionConfig)

Method Detail

getPartitionedState

protected <S extends State> S getPartitionedState(StateDescriptor<S,?> stateDescriptor)
                                           throws Exception

Overrides:

getPartitionedState in class DefaultKeyedStateStore

Throws:

Exception