org.apache.iceberg.flink

Class IcebergTableSource

java.lang.Object

org.apache.iceberg.flink.IcebergTableSource

All Implemented Interfaces:

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

public class IcebergTableSource
extends java.lang.Object
implements org.apache.flink.table.sources.StreamTableSource<org.apache.flink.table.data.RowData>, org.apache.flink.table.sources.ProjectableTableSource<org.apache.flink.table.data.RowData>

Flink Iceberg table source. TODO: Implement FilterableTableSource and LimitableTableSource.

Constructor Summary

Constructors

Constructor and Description
IcebergTableSource(TableLoader loader, org.apache.flink.table.api.TableSchema schema, java.util.Map<java.lang.String,java.lang.String> properties)

Method Summary

Modifier and Type	Method and Description
java.lang.String	explainSource()
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()
org.apache.flink.table.sources.TableSource<org.apache.flink.table.data.RowData>	projectFields(int[] fields)

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

getReturnType

Constructor Detail

IcebergTableSource

public IcebergTableSource(TableLoader loader,
                          org.apache.flink.table.api.TableSchema schema,
                          java.util.Map<java.lang.String,java.lang.String> properties)

Method Detail

isBounded

public boolean isBounded()

Specified by:

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

projectFields

public org.apache.flink.table.sources.TableSource<org.apache.flink.table.data.RowData> projectFields(int[] fields)

Specified by:

projectFields in interface org.apache.flink.table.sources.ProjectableTableSource<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>

explainSource

public java.lang.String explainSource()

Specified by:

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