lambda$getNextBatch$2(List) |  | 0% |  | 0% | 11 | 11 | 56 | 56 | 1 | 1 |
HiveSplitSource(ConnectorSession, String, String, CacheQuotaRequirement, HiveSplitSource.PerBucket, int, DataSize, HiveSplitLoader, CounterStat, boolean, double) |  | 0% |  | 0% | 3 | 3 | 24 | 24 | 1 | 1 |
addToQueue(InternalHiveSplit) |  | 0% |  | 0% | 5 | 5 | 14 | 14 | 1 | 1 |
getNextBatch(ConnectorPartitionHandle, int) |  | 0% |  | 0% | 5 | 5 | 14 | 14 | 1 | 1 |
isFinished() |  | 0% |  | 0% | 6 | 6 | 7 | 7 | 1 | 1 |
lambda$getNextBatch$3(boolean, OptionalInt, List) |  | 0% |  | 0% | 4 | 4 | 4 | 4 | 1 | 1 |
propagatePrestoException(Throwable) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
addToQueue(List) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
allAtOnce(ConnectorSession, String, String, CacheQuotaRequirement, int, int, DataSize, HiveSplitLoader, Executor, CounterStat, double) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
bucketed(ConnectorSession, String, String, CacheQuotaRequirement, int, int, DataSize, HiveSplitLoader, Executor, CounterStat, double) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
bucketedRewindable(ConnectorSession, String, String, CacheQuotaRequirement, int, DataSize, HiveSplitLoader, Executor, CounterStat, double) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setIf(AtomicReference, Object, Predicate) |  | 0% |  | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
fail(Throwable) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
noMoreSplits() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
close() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
lambda$close$4(HiveSplitSource.State) |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
rewind(ConnectorPartitionHandle) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
toBucketNumber(ConnectorPartitionHandle) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
lambda$fail$1(HiveSplitSource.State) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$noMoreSplits$0(HiveSplitSource.State) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
getBufferedInternalSplitCount() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |