testSplitCacheQuota() |  | 0% |  | 0% | 3 | 3 | 18 | 18 | 1 | 1 |
testFail() |  | 0% |  | 0% | 2 | 2 | 25 | 25 | 1 | 1 |
testPreloadSplitsForRewindableSplitSource() |  | 0% |  | 0% | 3 | 3 | 22 | 22 | 1 | 1 |
testOutstandingSplitSize() |  | 0% |  | 0% | 3 | 3 | 19 | 19 | 1 | 1 |
testRewindMultipleBuckets() |  | 0% |  | 0% | 2 | 2 | 16 | 16 | 1 | 1 |
testRewindOneBucket() |  | 0% |  | 0% | 2 | 2 | 17 | 17 | 1 | 1 |
testAffinitySchedulingKey() |  | 0% |  | 0% | 3 | 3 | 14 | 14 | 1 | 1 |
testEvenlySizedSplitRemainder() |  | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
testOutstandingSplitCount() |  | 0% |  | 0% | 2 | 2 | 11 | 11 | 1 | 1 |
testReaderWaitsForSplits() |  | 0% | | n/a | 1 | 1 | 14 | 14 | 1 | 1 |
testEmptyBucket() |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
getSplits(ConnectorSplitSource, OptionalInt, int) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
lambda$testReaderWaitsForSplits$1(CountDownLatch, HiveSplitSource, SettableFuture) |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
lambda$testPreloadSplitsForRewindableSplitSource$2(CountDownLatch, HiveSplitSource, SettableFuture) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
getAffinitySchedulingKey(HiveSplit) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getSplits(ConnectorSplitSource, int) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getAffinitySchedulingKey$0(AtomicReference, String) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
TestHiveSplitSource() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |