Class TableScanUtil

  • public class TableScanUtil
    extends java.lang.Object
    • Method Detail

      • hasEqDeletes

        public 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. We will remove this method once both are supported.
      • hasDeletes

        public static boolean hasDeletes​(FileScanTask task)
      • planTaskGroups

        public static <T extends ScanTask> java.util.List<ScanTaskGroup<T>> planTaskGroups​(java.util.List<T> tasks,
                                                                                           long splitSize,
                                                                                           int lookback,
                                                                                           long openFileCost)
      • mergeTasks

        public static <T extends ScanTask> java.util.List<T> mergeTasks​(java.util.List<T> tasks)
      • adjustSplitSize

        public static long adjustSplitSize​(long scanSize,
                                           int parallelism,
                                           long splitSize)