org.apache.flink.table.runtime.arrow.serializers

Class RowArrowSerializer

java.lang.Object

org.apache.flink.table.runtime.arrow.serializers.ArrowSerializer<Row>

org.apache.flink.table.runtime.arrow.serializers.RowArrowSerializer

@Internal
public class RowArrowSerializer
extends ArrowSerializer<Row>

It takes Row as the input type.

Field Summary

Fields inherited from class org.apache.flink.table.runtime.arrow.serializers.ArrowSerializer

inputType, outputType

Constructor Summary

Constructors

Constructor and Description
RowArrowSerializer(RowType inputType, RowType outputType)

Method Summary

Modifier and Type	Method and Description
ArrowReader<Row>	createArrowReader(org.apache.arrow.vector.VectorSchemaRoot root)
ArrowWriter<Row>	createArrowWriter() Creates an ArrowWriter.

Methods inherited from class org.apache.flink.table.runtime.arrow.serializers.ArrowSerializer

close, finishCurrentBatch, load, open, read, resetReader, resetWriter, write

Methods inherited from class java.lang.Object

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

Constructor Detail

RowArrowSerializer

public RowArrowSerializer(RowType inputType,
                          RowType outputType)

Method Detail

createArrowWriter

public ArrowWriter<Row> createArrowWriter()

Description copied from class: ArrowSerializer

Creates an ArrowWriter.

Specified by:

createArrowWriter in class ArrowSerializer<Row>

createArrowReader

public ArrowReader<Row> createArrowReader(org.apache.arrow.vector.VectorSchemaRoot root)

Specified by:

createArrowReader in class ArrowSerializer<Row>