org.apache.iceberg.flink.source.enumerator

Class 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 and Description
ContinuousSplitPlannerImpl(TableLoader tableLoader, ScanContext scanContext, java.lang.String threadName)

Method Summary

Modifier and Type	Method and 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(TableLoader tableLoader,
                                  ScanContext scanContext,
                                  java.lang.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 Detail

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

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