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

Class RowDataArrowSerializer

java.lang.Object

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

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

@Internal
public class RowDataArrowSerializer
extends ArrowSerializer<RowData>

It takes RowData 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
RowDataArrowSerializer(RowType inputType, RowType outputType)

Method Summary

Modifier and Type	Method and Description
ArrowReader<RowData>	createArrowReader(org.apache.arrow.vector.VectorSchemaRoot root)
ArrowWriter<RowData>	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

RowDataArrowSerializer

public RowDataArrowSerializer(RowType inputType,
                              RowType outputType)

Method Detail

createArrowWriter

public ArrowWriter<RowData> createArrowWriter()

Description copied from class: ArrowSerializer

Creates an ArrowWriter.

Specified by:

createArrowWriter in class ArrowSerializer<RowData>

createArrowReader

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

Specified by:

createArrowReader in class ArrowSerializer<RowData>