public static class IcebergSource.Builder<T>
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
IcebergSource.Builder<T> |
asOfTimestamp(java.lang.Long newAsOfTimestamp) |
IcebergSource.Builder<T> |
assignerFactory(SplitAssignerFactory assignerFactory) |
IcebergSource.Builder<T> |
branch(java.lang.String branch) |
IcebergSource<T> |
build() |
IcebergSource.Builder<T> |
caseSensitive(boolean newCaseSensitive) |
IcebergSource.Builder<T> |
endSnapshotId(java.lang.Long newEndSnapshotId) |
IcebergSource.Builder<T> |
endTag(java.lang.String endTag) |
IcebergSource.Builder<T> |
exposeLocality(boolean newExposeLocality) |
IcebergSource.Builder<T> |
filters(java.util.List<Expression> newFilters) |
IcebergSource.Builder<T> |
flinkConfig(org.apache.flink.configuration.ReadableConfig config) |
IcebergSource.Builder<T> |
includeColumnStats(boolean newIncludeColumnStats) |
IcebergSource.Builder<T> |
limit(java.lang.Long newLimit) |
IcebergSource.Builder<T> |
maxAllowedPlanningFailures(int maxAllowedPlanningFailures) |
IcebergSource.Builder<T> |
monitorInterval(java.time.Duration newMonitorInterval) |
IcebergSource.Builder<T> |
nameMapping(java.lang.String newNameMapping) |
IcebergSource.Builder<T> |
planParallelism(int planParallelism) |
IcebergSource.Builder<T> |
project(Schema newProjectedSchema) |
IcebergSource.Builder<T> |
project(org.apache.flink.table.api.TableSchema newProjectedFlinkSchema) |
IcebergSource.Builder<T> |
properties(java.util.Map<java.lang.String,java.lang.String> properties)
Deprecated.
|
IcebergSource.Builder<T> |
readerFunction(ReaderFunction<T> newReaderFunction) |
IcebergSource.Builder<T> |
set(java.lang.String property,
java.lang.String value)
Set the read properties for Flink source.
|
IcebergSource.Builder<T> |
setAll(java.util.Map<java.lang.String,java.lang.String> properties)
Set the read properties for Flink source.
|
IcebergSource.Builder<T> |
splitLookback(java.lang.Integer newSplitLookback) |
IcebergSource.Builder<T> |
splitOpenFileCost(java.lang.Long newSplitOpenFileCost) |
IcebergSource.Builder<T> |
splitSize(java.lang.Long newSplitSize) |
IcebergSource.Builder<T> |
startSnapshotId(java.lang.Long newStartSnapshotId) |
IcebergSource.Builder<T> |
startSnapshotTimestamp(java.lang.Long newStartSnapshotTimestamp) |
IcebergSource.Builder<T> |
startTag(java.lang.String startTag) |
IcebergSource.Builder<T> |
streaming(boolean streaming) |
IcebergSource.Builder<T> |
streamingStartingStrategy(StreamingStartingStrategy newStartingStrategy) |
IcebergSource.Builder<T> |
table(Table newTable) |
IcebergSource.Builder<T> |
tableLoader(TableLoader loader) |
IcebergSource.Builder<T> |
tag(java.lang.String tag) |
IcebergSource.Builder<T> |
useSnapshotId(java.lang.Long newSnapshotId) |
public IcebergSource.Builder<T> tableLoader(TableLoader loader)
public IcebergSource.Builder<T> table(Table newTable)
public IcebergSource.Builder<T> assignerFactory(SplitAssignerFactory assignerFactory)
public IcebergSource.Builder<T> readerFunction(ReaderFunction<T> newReaderFunction)
public IcebergSource.Builder<T> flinkConfig(org.apache.flink.configuration.ReadableConfig config)
public IcebergSource.Builder<T> caseSensitive(boolean newCaseSensitive)
public IcebergSource.Builder<T> useSnapshotId(java.lang.Long newSnapshotId)
public IcebergSource.Builder<T> streamingStartingStrategy(StreamingStartingStrategy newStartingStrategy)
public IcebergSource.Builder<T> startSnapshotTimestamp(java.lang.Long newStartSnapshotTimestamp)
public IcebergSource.Builder<T> startSnapshotId(java.lang.Long newStartSnapshotId)
public IcebergSource.Builder<T> tag(java.lang.String tag)
public IcebergSource.Builder<T> branch(java.lang.String branch)
public IcebergSource.Builder<T> startTag(java.lang.String startTag)
public IcebergSource.Builder<T> endTag(java.lang.String endTag)
public IcebergSource.Builder<T> endSnapshotId(java.lang.Long newEndSnapshotId)
public IcebergSource.Builder<T> asOfTimestamp(java.lang.Long newAsOfTimestamp)
public IcebergSource.Builder<T> splitSize(java.lang.Long newSplitSize)
public IcebergSource.Builder<T> splitLookback(java.lang.Integer newSplitLookback)
public IcebergSource.Builder<T> splitOpenFileCost(java.lang.Long newSplitOpenFileCost)
public IcebergSource.Builder<T> streaming(boolean streaming)
public IcebergSource.Builder<T> monitorInterval(java.time.Duration newMonitorInterval)
public IcebergSource.Builder<T> nameMapping(java.lang.String newNameMapping)
public IcebergSource.Builder<T> project(Schema newProjectedSchema)
public IcebergSource.Builder<T> project(org.apache.flink.table.api.TableSchema newProjectedFlinkSchema)
public IcebergSource.Builder<T> filters(java.util.List<Expression> newFilters)
public IcebergSource.Builder<T> limit(java.lang.Long newLimit)
public IcebergSource.Builder<T> includeColumnStats(boolean newIncludeColumnStats)
public IcebergSource.Builder<T> planParallelism(int planParallelism)
public IcebergSource.Builder<T> exposeLocality(boolean newExposeLocality)
public IcebergSource.Builder<T> maxAllowedPlanningFailures(int maxAllowedPlanningFailures)
public IcebergSource.Builder<T> set(java.lang.String property, java.lang.String value)
FlinkReadOptions
public IcebergSource.Builder<T> setAll(java.util.Map<java.lang.String,java.lang.String> properties)
FlinkReadOptions
@Deprecated public IcebergSource.Builder<T> properties(java.util.Map<java.lang.String,java.lang.String> properties)
setAll(java.util.Map<java.lang.String, java.lang.String>)
instead.public IcebergSource<T> build()