Package | Description |
---|---|
org.apache.flink.table.dataview | |
org.apache.flink.table.planner.functions.aggfunctions | |
org.apache.flink.table.runtime.dataview |
Modifier and Type | Method and Description |
---|---|
ListView<T> |
ListViewSerializer.copy(ListView<T> from) |
ListView<T> |
ListViewSerializer.copy(ListView<T> from,
ListView<T> reuse) |
ListView<T> |
ListViewSerializer.createInstance() |
ListView<T> |
ListViewSerializer.deserialize(DataInputView source) |
ListView<T> |
ListViewSerializer.deserialize(ListView<T> reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<ListView<T>> |
ListViewTypeInfo.createSerializer(ExecutionConfig config) |
TypeInformation<ListView<T>> |
ListViewTypeInfoFactory.createTypeInfo(Type t,
Map<String,TypeInformation<?>> genericParameters) |
TypeSerializer<ListView<T>> |
ListViewSerializer.duplicate() |
Class<ListView<T>> |
ListViewTypeInfo.getTypeClass() |
TypeSerializerSnapshot<ListView<T>> |
ListViewSerializer.snapshotConfiguration() |
<U> TypeSerializerSnapshot<ListView<T>> |
ListViewSerializer.transformLegacySerializerSnapshot(TypeSerializerSnapshot<U> legacySnapshot)
We need to override this as a
LegacySerializerSnapshotTransformer
because in Flink 1.6.x and below, this serializer was incorrectly returning
directly the snapshot of the nested list serializer as its own snapshot. |
Modifier and Type | Method and Description |
---|---|
ListView<T> |
ListViewSerializer.copy(ListView<T> from) |
ListView<T> |
ListViewSerializer.copy(ListView<T> from,
ListView<T> reuse) |
ListView<T> |
ListViewSerializer.copy(ListView<T> from,
ListView<T> reuse) |
ListView<T> |
ListViewSerializer.deserialize(ListView<T> reuse,
DataInputView source) |
void |
ListViewSerializer.serialize(ListView<T> record,
DataOutputView target) |
Modifier and Type | Field and Description |
---|---|
ListView<BinaryString> |
ListAggWithRetractAggFunction.ListAggWithRetractAccumulator.list |
ListView<BinaryString> |
ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator.list |
ListView<BinaryString> |
ListAggWithRetractAggFunction.ListAggWithRetractAccumulator.retractList |
ListView<BinaryString> |
ListAggWsWithRetractAggFunction.ListAggWsWithRetractAccumulator.retractList |
Modifier and Type | Class and Description |
---|---|
class |
StateListView<N,T>
StateListView is a ListView which implemented using state backend. |
static class |
StateListView.KeyedStateListView<N,T>
StateListView.KeyedStateListView is an default implementation of StateListView whose
underlying is a keyed state. |
static class |
StateListView.NamespacedStateListView<N,T>
StateListView.NamespacedStateListView is an StateListView whose underlying is a keyed
and namespaced state. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.