@Internal
public class FlinkSplitPlanner
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static java.util.List<IcebergSourceSplit> |
planIcebergSourceSplits(Table table,
ScanContext context,
java.util.concurrent.ExecutorService workerPool)
This returns splits for the FLIP-27 source
|
public static java.util.List<IcebergSourceSplit> planIcebergSourceSplits(Table table, ScanContext context, java.util.concurrent.ExecutorService workerPool)