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 forward the state
registration to underlying
KeyedStateBackend . |
Modifier and Type | Method and Description |
---|---|
void |
NamespaceAggsHandleFunction.open(StateDataViewStore store)
Initialization method for the function.
|
void |
AggsHandleFunction.open(StateDataViewStore store)
Initialization method for the function.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.