-
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.
BatchSizePredictorImpl.Factory.create(RecordBatch batch,
double fragmentationFactor,
double safetyFactor)
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)
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)