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

Class ArrowSerializer<T>

java.lang.Object

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

Type Parameters:

T - type of the input elements.

Direct Known Subclasses:

RowArrowSerializer, RowDataArrowSerializer

@Internal
public abstract class ArrowSerializer<T>
extends Object

The base class ArrowSerializer which will serialize/deserialize RowType data to/from arrow bytes.

Field Summary

Fields

Modifier and Type	Field and Description
protected RowType	inputType The input RowType.
protected RowType	outputType The output RowType.

Constructor Summary

Constructors

Constructor and Description
ArrowSerializer(RowType inputType, RowType outputType)

Method Summary

Modifier and Type	Method and Description
void	close()
abstract ArrowReader<T>	createArrowReader(org.apache.arrow.vector.VectorSchemaRoot root)
abstract ArrowWriter<T>	createArrowWriter() Creates an ArrowWriter.
void	finishCurrentBatch() Forces to finish the processing of the current batch of elements.
int	load()
void	open(InputStream bais, OutputStream baos)
T	read(int i)
void	resetReader()
void	resetWriter()
void	write(T element)

Methods inherited from class java.lang.Object

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

Field Detail

inputType

protected final RowType inputType

The input RowType.

outputType

protected final RowType outputType

The output RowType.

Constructor Detail

ArrowSerializer

public ArrowSerializer(RowType inputType,
                       RowType outputType)

Method Detail

open

public void open(InputStream bais,
                 OutputStream baos)
          throws Exception

Throws:

Exception

load

public int load()
         throws IOException

Throws:

IOException

read

public T read(int i)

write

public void write(T element)

close

public void close()
           throws Exception

Throws:

Exception

createArrowWriter

public abstract ArrowWriter<T> createArrowWriter()

Creates an ArrowWriter.

createArrowReader

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

finishCurrentBatch

public void finishCurrentBatch()
                        throws Exception

Forces to finish the processing of the current batch of elements. It will serialize the batch of elements into one arrow batch.

Throws:

Exception

resetReader

public void resetReader()
                 throws IOException

Throws:

IOException

resetWriter

public void resetWriter()
                 throws IOException

Throws:

IOException