org.apache.flink.table.runtime.arrow.sources

Class ArrowTableSource

java.lang.Object

org.apache.flink.table.runtime.arrow.sources.ArrowTableSource

All Implemented Interfaces:

StreamTableSource<RowData>, TableSource<RowData>

@Internal
public class ArrowTableSource
extends Object
implements StreamTableSource<RowData>

A StreamTableSource for serialized arrow record batch data.

Constructor Summary

Constructors

Constructor and Description
ArrowTableSource(DataType dataType, byte[][] arrowData)

Method Summary

Modifier and Type	Method and Description
DataStream<RowData>	getDataStream(StreamExecutionEnvironment execEnv) Returns the data of the table as a DataStream.
DataType	getProducedDataType() Returns the DataType for the produced data of the TableSource.
TableSchema	getTableSchema() Returns the schema of the produced table.
boolean	isBounded() Returns true if this is a bounded source, false if this is an unbounded source.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.sources.TableSource

explainSource, getReturnType

Constructor Detail

ArrowTableSource

public ArrowTableSource(DataType dataType,
                        byte[][] arrowData)

Method Detail

isBounded

public boolean isBounded()

Description copied from interface: StreamTableSource

Returns true if this is a bounded source, false if this is an unbounded source. Default is unbounded for compatibility.

Specified by:

isBounded in interface StreamTableSource<RowData>

getDataStream

public DataStream<RowData> getDataStream(StreamExecutionEnvironment execEnv)

Description copied from interface: StreamTableSource

Returns the data of the table as a DataStream.

NOTE: This method is for internal use only for defining a TableSource. Do not use it in Table API programs.

Specified by:

getDataStream in interface StreamTableSource<RowData>

getTableSchema

public TableSchema getTableSchema()

Description copied from interface: TableSource

Returns the schema of the produced table.

Specified by:

getTableSchema in interface TableSource<RowData>

Returns:

The TableSchema of the produced table.

getProducedDataType

public DataType getProducedDataType()

Description copied from interface: TableSource

Returns the DataType for the produced data of the TableSource.

Specified by:

getProducedDataType in interface TableSource<RowData>

Returns:

The data type of the returned DataStream.