Package | Description |
---|---|
org.apache.flink.table.runtime.dataview | |
org.apache.flink.table.runtime.generated |
Modifier and Type | Class and Description |
---|---|
class |
PerKeyStateDataViewStore
Default implementation of
StateDataViewStore that currently forwards state registration
to a RuntimeContext . |
class |
PerWindowStateDataViewStore
An implementation of
StateDataViewStore for window aggregates which forwards the state
registration to an underlying KeyedStateBackend . |
class |
UnsupportedStateDataViewStore
|
Modifier and Type | Method and Description |
---|---|
void |
NamespaceAggsHandleFunctionBase.open(StateDataViewStore store)
Initialization method for the function.
|
void |
AggsHandleFunctionBase.open(StateDataViewStore store)
Initialization method for the function.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.