public static class IcebergSource.Builder<T>
extends java.lang.Object
public IcebergSource.Builder<T> tableLoader(TableLoader loader)
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> 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(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> properties(java.util.Map<java.lang.String,java.lang.String> properties)
public IcebergSource<T> build()