Package org.apache.iceberg.flink.source

Class FlinkSplitPlanner

java.lang.Object

org.apache.iceberg.flink.source.FlinkSplitPlanner

@Internal
public class FlinkSplitPlanner
extends Object

Method Summary

Modifier and Type	Method	Description
static List<IcebergSourceSplit>	planIcebergSourceSplits(Table table, ScanContext context, 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 Details

planIcebergSourceSplits

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

This returns splits for the FLIP-27 source