public class TableScanUtil
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static boolean |
hasDeletes(CombinedScanTask task) |
static boolean |
hasDeletes(FileScanTask task) |
static boolean |
hasEqDeletes(CombinedScanTask task)
This is temporarily introduced since we plan to support pos-delete vectorized read first, then
get to the equality-delete support.
|
static <T extends ScanTask> |
mergeTasks(java.util.List<T> tasks) |
static <T extends ScanTask> |
planTaskGroups(CloseableIterable<T> tasks,
long splitSize,
int lookback,
long openFileCost) |
static <T extends ScanTask> |
planTaskGroups(java.util.List<T> tasks,
long splitSize,
int lookback,
long openFileCost) |
static <T extends PartitionScanTask> |
planTaskGroups(java.util.List<T> tasks,
long splitSize,
int lookback,
long openFileCost,
Types.StructType groupingKeyType) |
static CloseableIterable<CombinedScanTask> |
planTasks(CloseableIterable<FileScanTask> splitFiles,
long splitSize,
int lookback,
long openFileCost) |
static CloseableIterable<FileScanTask> |
splitFiles(CloseableIterable<FileScanTask> tasks,
long splitSize) |
public static boolean hasDeletes(CombinedScanTask task)
public static boolean hasEqDeletes(CombinedScanTask task)
public static boolean hasDeletes(FileScanTask task)
public static CloseableIterable<FileScanTask> splitFiles(CloseableIterable<FileScanTask> tasks, long splitSize)
public static CloseableIterable<CombinedScanTask> planTasks(CloseableIterable<FileScanTask> splitFiles, long splitSize, int lookback, long openFileCost)
public static <T extends ScanTask> java.util.List<ScanTaskGroup<T>> planTaskGroups(java.util.List<T> tasks, long splitSize, int lookback, long openFileCost)
public static <T extends ScanTask> CloseableIterable<ScanTaskGroup<T>> planTaskGroups(CloseableIterable<T> tasks, long splitSize, int lookback, long openFileCost)
public static <T extends PartitionScanTask> java.util.List<ScanTaskGroup<T>> planTaskGroups(java.util.List<T> tasks, long splitSize, int lookback, long openFileCost, Types.StructType groupingKeyType)
public static <T extends ScanTask> java.util.List<T> mergeTasks(java.util.List<T> tasks)