Package org.apache.iceberg.flink.source.enumerator

Class ContinuousSplitPlannerImpl

java.lang.Object

org.apache.iceberg.flink.source.enumerator.ContinuousSplitPlannerImpl

All Implemented Interfaces:

Closeable, AutoCloseable, ContinuousSplitPlanner

@Internal
public class ContinuousSplitPlannerImpl
extends Object
implements ContinuousSplitPlanner

Constructor Summary

Constructors

Constructor	Description
ContinuousSplitPlannerImpl(TableLoader tableLoader, ScanContext scanContext, String threadName)

Method Summary

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 Details

ContinuousSplitPlannerImpl

public ContinuousSplitPlannerImpl(TableLoader tableLoader,
 ScanContext scanContext,
 String threadName)

Parameters:

tableLoader - A cloned tableLoader.

threadName - thread name prefix for worker pool to run the split planning. If null, a shared worker pool will be used.

Method Details

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

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