public class PerWindowStateDataViewStore extends Object implements StateDataViewStore
KeyedStateBackend
. The created state by this store has the
ability to switch window namespace.Constructor and Description |
---|
PerWindowStateDataViewStore(KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> windowSerializer,
RuntimeContext runtimeContext) |
Modifier and Type | Method and Description |
---|---|
RuntimeContext |
getRuntimeContext()
Gets the context that contains information about the UDF's runtime, such as the parallelism
of the function, the subtask index of the function, or the name of the of the task that
executes the function.
|
<N,V> StateListView<N,V> |
getStateListView(String stateName,
ListViewTypeInfo<V> listViewTypeInfo)
Creates a state list view.
|
<N,UK,UV> StateMapView<N,UK,UV> |
getStateMapView(String stateName,
MapViewTypeInfo<UK,UV> mapViewTypeInfo)
Creates a state map view.
|
public PerWindowStateDataViewStore(KeyedStateBackend<?> keyedStateBackend, TypeSerializer<?> windowSerializer, RuntimeContext runtimeContext)
public <N,UK,UV> StateMapView<N,UK,UV> getStateMapView(String stateName, MapViewTypeInfo<UK,UV> mapViewTypeInfo) throws Exception
StateDataViewStore
getStateMapView
in interface StateDataViewStore
N
- Type of the namespaceUK
- Type of the keys in the map stateUV
- Type of the values in the map statestateName
- The name of underlying state of the map viewmapViewTypeInfo
- The type of the map viewException
public <N,V> StateListView<N,V> getStateListView(String stateName, ListViewTypeInfo<V> listViewTypeInfo) throws Exception
StateDataViewStore
getStateListView
in interface StateDataViewStore
N
- Type of the namespaceV
- Type of the elements in the list statestateName
- The name of underlying state of the list viewlistViewTypeInfo
- The type of the list viewException
public RuntimeContext getRuntimeContext()
StateDataViewStore
getRuntimeContext
in interface StateDataViewStore
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.