org.apache.flink.table.data.columnar

Class ColumnarMapData

java.lang.Object

org.apache.flink.table.data.columnar.ColumnarMapData

All Implemented Interfaces:

MapData

@Internal
public final class ColumnarMapData
extends Object
implements MapData

Columnar map to support access to vector column data.

Constructor Summary

Constructors

Constructor and Description
ColumnarMapData(ColumnVector keyColumnVector, ColumnVector valueColumnVector, int offset, int numElements)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
int	hashCode()
ArrayData	keyArray() Returns an array view of the keys contained in this map.
int	size() Returns the number of key-value mappings in this map.
ArrayData	valueArray() Returns an array view of the values contained in this map.

Methods inherited from class java.lang.Object

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

Constructor Detail

ColumnarMapData

public ColumnarMapData(ColumnVector keyColumnVector,
                       ColumnVector valueColumnVector,
                       int offset,
                       int numElements)

Method Detail

size

public int size()

Description copied from interface: MapData

Returns the number of key-value mappings in this map.

Specified by:

size in interface MapData

keyArray

public ArrayData keyArray()

Description copied from interface: MapData

Returns an array view of the keys contained in this map.

A key-value pair has the same index in the key array and value array.

Specified by:

keyArray in interface MapData

valueArray

public ArrayData valueArray()

Description copied from interface: MapData

Returns an array view of the values contained in this map.

A key-value pair has the same index in the key array and value array.

Specified by:

valueArray in interface MapData

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object