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

Class RowArrowTableSource

java.lang.Object

org.apache.flink.table.runtime.arrow.sources.AbstractArrowTableSource<Row>

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

All Implemented Interfaces:

StreamTableSource<Row>, TableSource<Row>

@Internal
public class RowArrowTableSource
extends AbstractArrowTableSource<Row>

An Arrow TableSource which takes Row as the type of the produced records.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
DataStream<Row>	getDataStream(StreamExecutionEnvironment execEnv) Returns the data of the table as a DataStream.

Methods inherited from class org.apache.flink.table.runtime.arrow.sources.AbstractArrowTableSource

getProducedDataType, getTableSchema, isBounded

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

RowArrowTableSource

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

Method Detail

getDataStream

public DataStream<Row> 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.