org.apache.iceberg.flink

Class FlinkReadConf

java.lang.Object

org.apache.iceberg.flink.FlinkReadConf

public class FlinkReadConf
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
FlinkReadConf(Table table, java.util.Map<java.lang.String,java.lang.String> readOptions, org.apache.flink.configuration.ReadableConfig readableConfig)

Method Summary

Modifier and Type	Method and Description
java.lang.Long	asOfTimestamp()
java.lang.String	branch()
boolean	caseSensitive()
java.lang.Long	endSnapshotId()
java.lang.String	endTag()
boolean	includeColumnStats()
long	limit()
int	maxAllowedPlanningFailures()
int	maxPlanningSnapshotCount()
java.time.Duration	monitorInterval()
java.lang.String	nameMapping()
java.lang.Long	snapshotId()
long	splitFileOpenCost()
int	splitLookback()
long	splitSize()
StreamingStartingStrategy	startingStrategy()
java.lang.Long	startSnapshotId()
java.lang.Long	startSnapshotTimestamp()
java.lang.String	startTag()
boolean	streaming()
java.lang.String	tag()
int	workerPoolSize()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlinkReadConf

public FlinkReadConf(Table table,
                     java.util.Map<java.lang.String,java.lang.String> readOptions,
                     org.apache.flink.configuration.ReadableConfig readableConfig)

Method Detail

snapshotId

public java.lang.Long snapshotId()

tag

public java.lang.String tag()

startTag

public java.lang.String startTag()

endTag

public java.lang.String endTag()

branch

public java.lang.String branch()

caseSensitive

public boolean caseSensitive()

asOfTimestamp

public java.lang.Long asOfTimestamp()

startingStrategy

public StreamingStartingStrategy startingStrategy()

startSnapshotTimestamp

public java.lang.Long startSnapshotTimestamp()

startSnapshotId

public java.lang.Long startSnapshotId()

endSnapshotId

public java.lang.Long endSnapshotId()

splitSize

public long splitSize()

splitLookback

public int splitLookback()

splitFileOpenCost

public long splitFileOpenCost()

streaming

public boolean streaming()

monitorInterval

public java.time.Duration monitorInterval()

includeColumnStats

public boolean includeColumnStats()

maxPlanningSnapshotCount

public int maxPlanningSnapshotCount()

nameMapping

public java.lang.String nameMapping()

limit

public long limit()

workerPoolSize

public int workerPoolSize()

maxAllowedPlanningFailures

public int maxAllowedPlanningFailures()