Package | Description |
---|---|
org.apache.flink.runtime.state | |
org.apache.flink.streaming.api.functions.windowing | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.scala.function | |
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations
on data streams.
|
org.apache.flink.streaming.runtime.operators.windowing.functions |
Modifier and Type | Class and Description |
---|---|
class |
DefaultKeyedStateStore
Default implementation of KeyedStateStore that currently forwards state registration to a
RuntimeContext . |
Modifier and Type | Method and Description |
---|---|
KeyedStateStore |
StateInitializationContextImpl.getKeyedStateStore() |
KeyedStateStore |
ManagedInitializationContext.getKeyedStateStore()
Returns an interface that allows for registering keyed state with the backend.
|
Constructor and Description |
---|
StateInitializationContextImpl(boolean restored,
OperatorStateStore operatorStateStore,
KeyedStateStore keyedStateStore,
Collection<KeyedStateHandle> keyedStateHandles,
Collection<OperatorStateHandle> operatorStateHandles,
CloseableRegistry closableRegistry) |
Modifier and Type | Method and Description |
---|---|
abstract KeyedStateStore |
ProcessWindowFunction.Context.globalState()
State accessor for per-key global state.
|
abstract KeyedStateStore |
ProcessAllWindowFunction.Context.globalState()
State accessor for per-key global state.
|
KeyedStateStore |
InternalProcessApplyWindowContext.globalState() |
KeyedStateStore |
InternalProcessApplyAllWindowContext.globalState() |
abstract KeyedStateStore |
ProcessWindowFunction.Context.windowState()
State accessor for per-key and per-window state.
|
abstract KeyedStateStore |
ProcessAllWindowFunction.Context.windowState()
State accessor for per-key and per-window state.
|
KeyedStateStore |
InternalProcessApplyWindowContext.windowState() |
KeyedStateStore |
InternalProcessApplyAllWindowContext.windowState() |
Modifier and Type | Method and Description |
---|---|
KeyedStateStore |
AbstractStreamOperator.getKeyedStateStore() |
Modifier and Type | Method and Description |
---|---|
abstract KeyedStateStore |
ProcessAllWindowFunction.Context.globalState()
State accessor for per-key global state.
|
abstract KeyedStateStore |
ProcessWindowFunction.Context.globalState()
State accessor for per-key global state.
|
abstract KeyedStateStore |
ProcessAllWindowFunction.Context.windowState()
State accessor for per-key and per-window state.
|
abstract KeyedStateStore |
ProcessWindowFunction.Context.windowState()
State accessor for per-key and per-window state.
|
Modifier and Type | Class and Description |
---|---|
class |
WindowOperator.AbstractPerWindowStateStore
Base class for per-window
KeyedStateStores . |
class |
WindowOperator.MergingWindowStateStore
Special
WindowOperator.AbstractPerWindowStateStore that doesn't allow access to per-window state. |
class |
WindowOperator.PerWindowStateStore
Regular per-window state store for use with
ProcessWindowFunction . |
Modifier and Type | Method and Description |
---|---|
KeyedStateStore |
WindowOperator.WindowContext.globalState() |
KeyedStateStore |
WindowOperator.WindowContext.windowState() |
Modifier and Type | Method and Description |
---|---|
KeyedStateStore |
InternalWindowFunction.InternalWindowContext.globalState() |
KeyedStateStore |
InternalProcessWindowContext.globalState() |
KeyedStateStore |
InternalProcessAllWindowContext.globalState() |
KeyedStateStore |
InternalWindowFunction.InternalWindowContext.windowState() |
KeyedStateStore |
InternalProcessWindowContext.windowState() |
KeyedStateStore |
InternalProcessAllWindowContext.windowState() |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.