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–2020 The Apache Software Foundation. All rights reserved.