ContinuousSplitPlannerImpl

java.lang.Object
- org.apache.iceberg.flink.source.enumerator.ContinuousSplitPlannerImpl

All Implemented Interfaces:: java.io.Closeable, java.lang.AutoCloseable, ContinuousSplitPlanner

@Internal
public class ContinuousSplitPlannerImpl
extends java.lang.Object
implements ContinuousSplitPlanner

Constructor Summary

Constructors
Constructor Description

ContinuousSplitPlannerImpl(Table table, ScanContext scanContext, java.lang.String threadName)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`close()`
`org.apache.iceberg.flink.source.enumerator.ContinuousEnumerationResult`	`planSplits(org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorPosition lastPosition)`	Discover the files appended between `lastPosition` and current table snapshot

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - ContinuousSplitPlannerImpl
```
public ContinuousSplitPlannerImpl(Table table,
                                  ScanContext scanContext,
                                  java.lang.String threadName)
```
    Parameters:
    
    threadName - thread name prefix for worker pool to run the split planning. If null, a shared worker pool will be used.
- Method Detail
  - close
```
public void close()
           throws java.io.IOException
```
    Specified by:
    
    close in interface java.lang.AutoCloseable
    
    Specified by:
    
    close in interface java.io.Closeable
    
    Throws:
    
    java.io.IOException
  - planSplits
```
public org.apache.iceberg.flink.source.enumerator.ContinuousEnumerationResult planSplits(org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorPosition lastPosition)
```
    Description copied from interface: ContinuousSplitPlanner
    
    Discover the files appended between lastPosition and current table snapshot
    
    Specified by:
    
    planSplits in interface ContinuousSplitPlanner