Package org.apache.iceberg.flink.source

Class FlinkSplitPlanner

java.lang.Object

org.apache.iceberg.flink.source.FlinkSplitPlanner

@Internal
public class FlinkSplitPlanner
extends java.lang.Object

Method Summary

Modifier and Type	Method	Description
static java.util.List<IcebergSourceSplit>	planIcebergSourceSplits(Table table, ScanContext context, java.util.concurrent.ExecutorService workerPool)	This returns splits for the FLIP-27 source

Methods inherited from class java.lang.Object

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

Method Detail

planIcebergSourceSplits

public static java.util.List<IcebergSourceSplit> planIcebergSourceSplits(Table table,
                                                                         ScanContext context,
                                                                         java.util.concurrent.ExecutorService workerPool)

This returns splits for the FLIP-27 source