public static class FlinkSource.Builder
extends java.lang.Object
DataStream
.Constructor and Description |
---|
Builder() |
Modifier and Type | Method and Description |
---|---|
FlinkSource.Builder |
asOfTimestamp(java.lang.Long asOfTimestamp) |
org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> |
build() |
FlinkInputFormat |
buildFormat() |
FlinkSource.Builder |
caseSensitive(boolean caseSensitive) |
FlinkSource.Builder |
endSnapshotId(java.lang.Long endSnapshotId) |
FlinkSource.Builder |
env(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment newEnv) |
FlinkSource.Builder |
filters(java.util.List<Expression> filters) |
FlinkSource.Builder |
nameMapping(java.lang.String nameMapping) |
FlinkSource.Builder |
project(org.apache.flink.table.api.TableSchema schema) |
FlinkSource.Builder |
properties(java.util.Map<java.lang.String,java.lang.String> properties) |
FlinkSource.Builder |
snapshotId(java.lang.Long snapshotId) |
FlinkSource.Builder |
splitLookback(java.lang.Integer splitLookback) |
FlinkSource.Builder |
splitOpenFileCost(java.lang.Long splitOpenFileCost) |
FlinkSource.Builder |
splitSize(java.lang.Long splitSize) |
FlinkSource.Builder |
startSnapshotId(java.lang.Long startSnapshotId) |
FlinkSource.Builder |
table(Table newTable) |
FlinkSource.Builder |
tableLoader(TableLoader newLoader) |
public FlinkSource.Builder tableLoader(TableLoader newLoader)
public FlinkSource.Builder table(Table newTable)
public FlinkSource.Builder env(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment newEnv)
public FlinkSource.Builder filters(java.util.List<Expression> filters)
public FlinkSource.Builder project(org.apache.flink.table.api.TableSchema schema)
public FlinkSource.Builder properties(java.util.Map<java.lang.String,java.lang.String> properties)
public FlinkSource.Builder caseSensitive(boolean caseSensitive)
public FlinkSource.Builder snapshotId(java.lang.Long snapshotId)
public FlinkSource.Builder startSnapshotId(java.lang.Long startSnapshotId)
public FlinkSource.Builder endSnapshotId(java.lang.Long endSnapshotId)
public FlinkSource.Builder asOfTimestamp(java.lang.Long asOfTimestamp)
public FlinkSource.Builder splitSize(java.lang.Long splitSize)
public FlinkSource.Builder splitLookback(java.lang.Integer splitLookback)
public FlinkSource.Builder splitOpenFileCost(java.lang.Long splitOpenFileCost)
public FlinkSource.Builder nameMapping(java.lang.String nameMapping)
public FlinkInputFormat buildFormat()
public org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> build()