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) |
FlinkSource.Builder |
branch(java.lang.String branch) |
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 |
endTag(java.lang.String endTag) |
FlinkSource.Builder |
env(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment newEnv) |
FlinkSource.Builder |
exposeLocality(boolean newExposeLocality) |
FlinkSource.Builder |
filters(java.util.List<Expression> filters) |
FlinkSource.Builder |
flinkConf(org.apache.flink.configuration.ReadableConfig config) |
FlinkSource.Builder |
limit(java.lang.Long newLimit) |
FlinkSource.Builder |
maxPlanningSnapshotCount(int newMaxPlanningSnapshotCount) |
FlinkSource.Builder |
monitorInterval(java.time.Duration interval) |
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)
Deprecated.
|
FlinkSource.Builder |
set(java.lang.String property,
java.lang.String value) |
FlinkSource.Builder |
setAll(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 |
startTag(java.lang.String startTag) |
FlinkSource.Builder |
streaming(boolean streaming) |
FlinkSource.Builder |
table(Table newTable) |
FlinkSource.Builder |
tableLoader(TableLoader newLoader) |
FlinkSource.Builder |
tag(java.lang.String tag) |
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 limit(java.lang.Long newLimit)
public FlinkSource.Builder set(java.lang.String property, java.lang.String value)
public FlinkSource.Builder setAll(java.util.Map<java.lang.String,java.lang.String> properties)
@Deprecated public FlinkSource.Builder properties(java.util.Map<java.lang.String,java.lang.String> properties)
setAll(java.util.Map<java.lang.String, java.lang.String>)
instead.public FlinkSource.Builder caseSensitive(boolean caseSensitive)
public FlinkSource.Builder snapshotId(java.lang.Long snapshotId)
public FlinkSource.Builder branch(java.lang.String branch)
public FlinkSource.Builder tag(java.lang.String tag)
public FlinkSource.Builder startSnapshotId(java.lang.Long startSnapshotId)
public FlinkSource.Builder endSnapshotId(java.lang.Long endSnapshotId)
public FlinkSource.Builder startTag(java.lang.String startTag)
public FlinkSource.Builder endTag(java.lang.String endTag)
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 streaming(boolean streaming)
public FlinkSource.Builder exposeLocality(boolean newExposeLocality)
public FlinkSource.Builder nameMapping(java.lang.String nameMapping)
public FlinkSource.Builder monitorInterval(java.time.Duration interval)
public FlinkSource.Builder maxPlanningSnapshotCount(int newMaxPlanningSnapshotCount)
public FlinkSource.Builder flinkConf(org.apache.flink.configuration.ReadableConfig config)
public FlinkInputFormat buildFormat()
public org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> build()