Package org.apache.flink.table.runtime.arrow.vectors

Class ArrowMapColumnVector

java.lang.Object

org.apache.flink.table.runtime.arrow.vectors.ArrowMapColumnVector

All Implemented Interfaces:

org.apache.flink.table.data.columnar.vector.ColumnVector, org.apache.flink.table.data.columnar.vector.MapColumnVector

@Internal
public final class ArrowMapColumnVector
extends Object
implements org.apache.flink.table.data.columnar.vector.MapColumnVector

Arrow column vector for Map.

Constructor Summary

Constructors

Constructor	Description
ArrowMapColumnVector(org.apache.arrow.vector.complex.MapVector mapVector, org.apache.flink.table.data.columnar.vector.ColumnVector keyVector, org.apache.flink.table.data.columnar.vector.ColumnVector valueVector)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.table.data.MapData	getMap(int i)
boolean	isNullAt(int i)

Methods inherited from class java.lang.Object

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

Constructor Detail

ArrowMapColumnVector

public ArrowMapColumnVector(org.apache.arrow.vector.complex.MapVector mapVector,
                            org.apache.flink.table.data.columnar.vector.ColumnVector keyVector,
                            org.apache.flink.table.data.columnar.vector.ColumnVector valueVector)

Method Detail

getMap

public org.apache.flink.table.data.MapData getMap(int i)

Specified by:

getMap in interface org.apache.flink.table.data.columnar.vector.MapColumnVector

isNullAt

public boolean isNullAt(int i)

Specified by:

isNullAt in interface org.apache.flink.table.data.columnar.vector.ColumnVector