java.lang.Object
- org.apache.iceberg.flink.FlinkReadConf

public class FlinkReadConf
extends java.lang.Object

Constructor Summary

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

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`java.lang.Long`	`asOfTimestamp()`
`java.lang.String`	`branch()`
`boolean`	`caseSensitive()`
`java.lang.Long`	`endSnapshotId()`
`java.lang.String`	`endTag()`
`boolean`	`includeColumnStats()`
`long`	`limit()`
`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()
```

Class FlinkReadConf

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

FlinkReadConf

Method Detail

snapshotId

tag

startTag

endTag

branch

caseSensitive

asOfTimestamp

startingStrategy

startSnapshotTimestamp

startSnapshotId

endSnapshotId

splitSize

splitLookback

splitFileOpenCost

streaming

monitorInterval

includeColumnStats

maxPlanningSnapshotCount

nameMapping

limit

workerPoolSize