org.apache.iceberg.flink

Class IcebergTableSource

java.lang.Object

org.apache.iceberg.flink.IcebergTableSource

All Implemented Interfaces:

org.apache.flink.table.sources.FilterableTableSource<org.apache.flink.table.data.RowData>, org.apache.flink.table.sources.LimitableTableSource<org.apache.flink.table.data.RowData>, 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>, org.apache.flink.table.sources.FilterableTableSource<org.apache.flink.table.data.RowData>, org.apache.flink.table.sources.LimitableTableSource<org.apache.flink.table.data.RowData>

Flink Iceberg table source.

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, org.apache.flink.configuration.ReadableConfig readableConfig)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.table.sources.TableSource<org.apache.flink.table.data.RowData>	applyLimit(long newLimit)
org.apache.flink.table.sources.TableSource<org.apache.flink.table.data.RowData>	applyPredicate(java.util.List<org.apache.flink.table.expressions.Expression> predicates)
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()
boolean	isFilterPushedDown()
boolean	isLimitPushedDown()
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,
                          org.apache.flink.configuration.ReadableConfig readableConfig)

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>

isLimitPushedDown

public boolean isLimitPushedDown()

Specified by:

isLimitPushedDown in interface org.apache.flink.table.sources.LimitableTableSource<org.apache.flink.table.data.RowData>

applyLimit

public org.apache.flink.table.sources.TableSource<org.apache.flink.table.data.RowData> applyLimit(long newLimit)

Specified by:

applyLimit in interface org.apache.flink.table.sources.LimitableTableSource<org.apache.flink.table.data.RowData>

applyPredicate

public org.apache.flink.table.sources.TableSource<org.apache.flink.table.data.RowData> applyPredicate(java.util.List<org.apache.flink.table.expressions.Expression> predicates)

Specified by:

applyPredicate in interface org.apache.flink.table.sources.FilterableTableSource<org.apache.flink.table.data.RowData>

isFilterPushedDown

public boolean isFilterPushedDown()

Specified by:

isFilterPushedDown in interface org.apache.flink.table.sources.FilterableTableSource<org.apache.flink.table.data.RowData>