Package org.apache.flink.table.runtime.dataview

Class StateListView<N,EE>

java.lang.Object

org.apache.flink.table.api.dataview.ListView<EE>

org.apache.flink.table.runtime.dataview.StateListView<N,EE>

Type Parameters:

EE - the external type of element in the ListView

All Implemented Interfaces:

org.apache.flink.table.api.dataview.DataView, StateDataView<N>

Direct Known Subclasses:

StateListView.KeyedStateListView, StateListView.NamespacedStateListView

@Internal
public abstract class StateListView<N,EE>
extends org.apache.flink.table.api.dataview.ListView<EE>
implements StateDataView<N>

StateListView is a ListView which is implemented using state backends.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StateListView.KeyedStateListView<N,T>	StateListView.KeyedStateListView is an default implementation of StateListView whose underlying representation is a keyed state.
static class	StateListView.NamespacedStateListView<N,T>	StateListView.NamespacedStateListView is an StateListView whose underlying representation is a keyed and namespaced state.

Field Summary

Fields inherited from class org.apache.flink.table.api.dataview.ListView

elementType

Constructor Summary

Constructors

Constructor	Description
StateListView()

Method Summary

Modifier and Type	Method	Description
void	add(EE value)
void	addAll(List<EE> list)
void	clear()
Iterable<EE>	get()
List<EE>	getList()
protected abstract org.apache.flink.api.common.state.ListState<EE>	getListState()
boolean	remove(EE value)
void	setList(List<EE> list)

Methods inherited from class org.apache.flink.table.api.dataview.ListView

equals, hashCode, newListViewDataType

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.table.runtime.dataview.StateDataView

setCurrentNamespace

Constructor Detail

StateListView

public StateListView()

Method Detail

getList

public List<EE> getList()

Overrides:

getList in class org.apache.flink.table.api.dataview.ListView<EE>

setList

public void setList(List<EE> list)

Overrides:

setList in class org.apache.flink.table.api.dataview.ListView<EE>

get

public Iterable<EE> get()
                 throws Exception

Overrides:

get in class org.apache.flink.table.api.dataview.ListView<EE>

Throws:

Exception

add

public void add(EE value)
         throws Exception

Overrides:

add in class org.apache.flink.table.api.dataview.ListView<EE>

Throws:

Exception

addAll

public void addAll(List<EE> list)
            throws Exception

Overrides:

addAll in class org.apache.flink.table.api.dataview.ListView<EE>

Throws:

Exception

remove

public boolean remove(EE value)
               throws Exception

Overrides:

remove in class org.apache.flink.table.api.dataview.ListView<EE>

Throws:

Exception

clear

public void clear()

Specified by:

clear in interface org.apache.flink.table.api.dataview.DataView

Overrides:

clear in class org.apache.flink.table.api.dataview.ListView<EE>

getListState

protected abstract org.apache.flink.api.common.state.ListState<EE> getListState()