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>
FilterableTableSource
and LimitableTableSource
.Constructor and Description |
---|
IcebergTableSource(TableLoader loader,
org.apache.flink.table.api.TableSchema schema,
java.util.Map<java.lang.String,java.lang.String> properties) |
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) |
public IcebergTableSource(TableLoader loader, org.apache.flink.table.api.TableSchema schema, java.util.Map<java.lang.String,java.lang.String> properties)
public boolean isBounded()
isBounded
in interface org.apache.flink.table.sources.StreamTableSource<org.apache.flink.table.data.RowData>
public org.apache.flink.table.sources.TableSource<org.apache.flink.table.data.RowData> projectFields(int[] fields)
projectFields
in interface org.apache.flink.table.sources.ProjectableTableSource<org.apache.flink.table.data.RowData>
public org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> getDataStream(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv)
getDataStream
in interface org.apache.flink.table.sources.StreamTableSource<org.apache.flink.table.data.RowData>
public org.apache.flink.table.api.TableSchema getTableSchema()
getTableSchema
in interface org.apache.flink.table.sources.TableSource<org.apache.flink.table.data.RowData>
public org.apache.flink.table.types.DataType getProducedDataType()
getProducedDataType
in interface org.apache.flink.table.sources.TableSource<org.apache.flink.table.data.RowData>
public java.lang.String explainSource()
explainSource
in interface org.apache.flink.table.sources.TableSource<org.apache.flink.table.data.RowData>