Uses of Interface
org.apache.drill.exec.physical.impl.join.BatchSizePredictor

Packages that use BatchSizePredictor

Package	Description
org.apache.drill.exec.physical.impl.join

Uses of BatchSizePredictor in org.apache.drill.exec.physical.impl.join

Classes in org.apache.drill.exec.physical.impl.join that implement BatchSizePredictor

Modifier and Type	Class and Description
class	BatchSizePredictorImpl
static class	TestBuildSidePartitioningImpl.MockBatchSizePredictor
static class	TestPostBuildCalculationsImpl.ConditionalMockBatchSizePredictor

Methods in org.apache.drill.exec.physical.impl.join that return BatchSizePredictor

Modifier and Type	Method and Description
BatchSizePredictor	BatchSizePredictor.Factory.create(RecordBatch batch, double fragmentationFactor, double safetyFactor) Creates a predictor with a batch whose data needs to be used to predict other batch sizes.
BatchSizePredictor	BatchSizePredictorImpl.Factory.create(RecordBatch batch, double fragmentationFactor, double safetyFactor)

Methods in org.apache.drill.exec.physical.impl.join with parameters of type BatchSizePredictor

Modifier and Type

Method and Description

protected void

HashJoinMemoryCalculatorImpl.BuildSidePartitioningImpl.initialize(boolean firstCycle, boolean reserveHash, CaseInsensitiveMap<Long> keySizes, long memoryAvailable, int initialPartitions, boolean probeEmpty, BatchSizePredictor buildSizePredictor, BatchSizePredictor probeSizePredictor, int recordsPerPartitionBatchBuild, int recordsPerPartitionBatchProbe, int maxBatchNumRecordsBuild, int maxBatchNumRecordsProbe, int outputBatchSize, double loadFactor)

Constructors in org.apache.drill.exec.physical.impl.join with parameters of type BatchSizePredictor

Constructor and Description

PostBuildCalculationsImpl(boolean firstCycle, BatchSizePredictor probeSizePredictor, long memoryAvailable, long maxOutputBatchSize, int maxBatchNumRecordsProbe, int recordsPerPartitionBatchProbe, HashJoinMemoryCalculator.PartitionStatSet buildPartitionStatSet, Map<String,Long> keySizes, HashTableSizeCalculator hashTableSizeCalculator, HashJoinHelperSizeCalculator hashJoinHelperSizeCalculator, double fragmentationFactor, double safetyFactor, double loadFactor, boolean reserveHash, boolean semiJoin)