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

Class ArrowTableSource

java.lang.Object

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

All Implemented Interfaces:

org.apache.flink.table.sources.StreamTableSource<org.apache.flink.table.data.RowData>, org.apache.flink.table.sources.TableSource<org.apache.flink.table.data.RowData>

@Internal
public class ArrowTableSource
extends Object
implements org.apache.flink.table.sources.StreamTableSource<org.apache.flink.table.data.RowData>

A StreamTableSource for serialized arrow record batch data.

Constructor Summary

Constructors

Constructor and Description
ArrowTableSource(org.apache.flink.table.types.DataType dataType, byte[][] arrowData)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData>	getDataStream(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv)
org.apache.flink.table.types.DataType	getProducedDataType()
org.apache.flink.table.api.TableSchema	getTableSchema()
boolean	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

ArrowTableSource

public ArrowTableSource(org.apache.flink.table.types.DataType dataType,
                        byte[][] arrowData)

Method Detail

isBounded

public boolean isBounded()

Specified by:

isBounded in interface org.apache.flink.table.sources.StreamTableSource<org.apache.flink.table.data.RowData>

getDataStream

public org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> getDataStream(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv)

Specified by:

getDataStream in interface org.apache.flink.table.sources.StreamTableSource<org.apache.flink.table.data.RowData>

getTableSchema

public org.apache.flink.table.api.TableSchema getTableSchema()

Specified by:

getTableSchema in interface org.apache.flink.table.sources.TableSource<org.apache.flink.table.data.RowData>

getProducedDataType

public org.apache.flink.table.types.DataType getProducedDataType()

Specified by:

getProducedDataType in interface org.apache.flink.table.sources.TableSource<org.apache.flink.table.data.RowData>