Package org.apache.flink.table.planner.typeutils

Class DataViewUtils.DistinctViewSpec

java.lang.Object

org.apache.flink.table.runtime.dataview.DataViewSpec

org.apache.flink.table.runtime.dataview.MapViewSpec

org.apache.flink.table.planner.typeutils.DataViewUtils.DistinctViewSpec

All Implemented Interfaces:

Serializable

Enclosing class:

DataViewUtils

public static class DataViewUtils.DistinctViewSpec
extends MapViewSpec

Specification for a special MapView for deduplication.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
DistinctViewSpec(String stateId, DataType distinctViewDataType)

Method Summary

Methods inherited from class org.apache.flink.table.runtime.dataview.MapViewSpec

containsNullKey, getKeyDataType, getKeySerializer, getValueDataType, getValueSerializer

Methods inherited from class org.apache.flink.table.runtime.dataview.DataViewSpec

getDataType, getFieldIndex, getStateId

Methods inherited from class java.lang.Object

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

Constructor Detail

DistinctViewSpec

public DistinctViewSpec(String stateId,
                        DataType distinctViewDataType)