|
Change Parameter Type probeBatchSize : long to probeEmpty : boolean in method protected initialize(autoTune boolean, reserveHash boolean, keySizes CaseInsensitiveMap<Long>, memoryAvailable long, maxIncomingBatchSize long, initialPartitions int, probeEmpty boolean, buildSizePredictor BatchSizePredictor, probeSizePredictor BatchSizePredictor, recordsPerPartitionBatchBuild int, recordsPerPartitionBatchProbe int, maxBatchNumRecordsBuild int, maxBatchNumRecordsProbe int, outputBatchSize int, loadFactor double) : void in class org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculatorImpl.BuildSidePartitioningImpl |
From |
To |
|
Change Parameter Type buildNumRecords : int to buildSizePredictor : BatchSizePredictor in method protected initialize(autoTune boolean, reserveHash boolean, keySizes CaseInsensitiveMap<Long>, memoryAvailable long, maxIncomingBatchSize long, initialPartitions int, probeEmpty boolean, buildSizePredictor BatchSizePredictor, probeSizePredictor BatchSizePredictor, recordsPerPartitionBatchBuild int, recordsPerPartitionBatchProbe int, maxBatchNumRecordsBuild int, maxBatchNumRecordsProbe int, outputBatchSize int, loadFactor double) : void in class org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculatorImpl.BuildSidePartitioningImpl |
From |
To |
|
Change Parameter Type probeNumRecords : int to probeSizePredictor : BatchSizePredictor in method protected initialize(autoTune boolean, reserveHash boolean, keySizes CaseInsensitiveMap<Long>, memoryAvailable long, maxIncomingBatchSize long, initialPartitions int, probeEmpty boolean, buildSizePredictor BatchSizePredictor, probeSizePredictor BatchSizePredictor, recordsPerPartitionBatchBuild int, recordsPerPartitionBatchProbe int, maxBatchNumRecordsBuild int, maxBatchNumRecordsProbe int, outputBatchSize int, loadFactor double) : void in class org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculatorImpl.BuildSidePartitioningImpl |
From |
To |
|
Move Method public getBatchSizeEstimate(recordBatch RecordBatch) : long from class org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculatorImpl.BuildSidePartitioningImpl to public getBatchSizeEstimate(recordBatch RecordBatch) : long from class org.apache.drill.exec.physical.impl.join.BatchSizePredictorImpl |
From |
To |
|
Move Method public computePartitionBatchSize(incomingBatchSize long, incomingNumRecords int, desiredNumRecords int) : long from class org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculatorImpl to public computePartitionBatchSize(incomingBatchSize long, incomingNumRecords int, desiredNumRecords int) : long from class org.apache.drill.exec.physical.impl.join.BatchSizePredictorImpl |
From |
To |
|
Move Method public computeValueVectorSize(numRecords long, byteSize long) : long from class org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculatorImpl.PostBuildCalculationsImpl to public computeValueVectorSize(numRecords long, byteSize long) : long from class org.apache.drill.exec.physical.impl.join.BatchSizePredictorImpl |
From |
To |
|
Move Method public computeMaxBatchSizeNoHash(incomingBatchSize long, incomingNumRecords int, desiredNumRecords int, fragmentationFactor double, safetyFactor double) : long from class org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculatorImpl to public computeMaxBatchSizeNoHash(incomingBatchSize long, incomingNumRecords int, desiredNumRecords int, fragmentationFactor double, safetyFactor double) : long from class org.apache.drill.exec.physical.impl.join.BatchSizePredictorImpl |
From |
To |
|
Move Method public testComputeValueVectorSizeNonPowerOf2() : void from class org.apache.drill.exec.physical.impl.join.TestPostBuildCalculationsImpl to public testComputeValueVectorSizeNonPowerOf2() : void from class org.apache.drill.exec.physical.impl.join.TestBatchSizePredictorImpl |
From |
To |
|
Move Method public computeMaxBatchSize(incomingBatchSize long, incomingNumRecords int, desiredNumRecords int, fragmentationFactor double, safetyFactor double, reserveHash boolean) : long from class org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculatorImpl to public computeMaxBatchSize(incomingBatchSize long, incomingNumRecords int, desiredNumRecords int, fragmentationFactor double, safetyFactor double, reserveHash boolean) : long from class org.apache.drill.exec.physical.impl.join.BatchSizePredictorImpl |
From |
To |
|
Move Method public computeValueVectorSize(numRecords long, byteSize long, safetyFactor double) : long from class org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculatorImpl.PostBuildCalculationsImpl to public computeValueVectorSize(numRecords long, byteSize long, safetyFactor double) : long from class org.apache.drill.exec.physical.impl.join.BatchSizePredictorImpl |
From |
To |
|
Move Method public roundUpToPowerOf2(num long) : long from class org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculatorImpl.PostBuildCalculationsImpl to public roundUpToPowerOf2(num long) : long from class org.apache.drill.exec.physical.impl.join.BatchSizePredictorImpl |
From |
To |
|
Move Method public testComputeValueVectorSizePowerOf2() : void from class org.apache.drill.exec.physical.impl.join.TestPostBuildCalculationsImpl to public testComputeValueVectorSizePowerOf2() : void from class org.apache.drill.exec.physical.impl.join.TestBatchSizePredictorImpl |
From |
To |
|
Rename Parameter probeBatchSize : long to probeEmpty : boolean in method protected initialize(autoTune boolean, reserveHash boolean, keySizes CaseInsensitiveMap<Long>, memoryAvailable long, maxIncomingBatchSize long, initialPartitions int, probeEmpty boolean, buildSizePredictor BatchSizePredictor, probeSizePredictor BatchSizePredictor, recordsPerPartitionBatchBuild int, recordsPerPartitionBatchProbe int, maxBatchNumRecordsBuild int, maxBatchNumRecordsProbe int, outputBatchSize int, loadFactor double) : void in class org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculatorImpl.BuildSidePartitioningImpl |
From |
To |
|
Rename Parameter buildSideBatch : RecordBatch to buildBatch : RecordBatch in method public initialize(autoTune boolean, reserveHash boolean, buildBatch RecordBatch, probeBatch RecordBatch, joinColumns Set<String>, probeEmpty boolean, memoryAvailable long, maxIncomingBatchSize long, initialPartitions int, recordsPerPartitionBatchBuild int, recordsPerPartitionBatchProbe int, maxBatchNumRecordsBuild int, maxBatchNumRecordsProbe int, outputBatchSize int, loadFactor double) : void in class org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculatorImpl.BuildSidePartitioningImpl |
From |
To |
|
Rename Parameter buildBatchSize : long to maxIncomingBatchSize : long in method protected initialize(autoTune boolean, reserveHash boolean, keySizes CaseInsensitiveMap<Long>, memoryAvailable long, maxIncomingBatchSize long, initialPartitions int, probeEmpty boolean, buildSizePredictor BatchSizePredictor, probeSizePredictor BatchSizePredictor, recordsPerPartitionBatchBuild int, recordsPerPartitionBatchProbe int, maxBatchNumRecordsBuild int, maxBatchNumRecordsProbe int, outputBatchSize int, loadFactor double) : void in class org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculatorImpl.BuildSidePartitioningImpl |
From |
To |
|
Rename Parameter probeNumRecords : int to probeSizePredictor : BatchSizePredictor in method protected initialize(autoTune boolean, reserveHash boolean, keySizes CaseInsensitiveMap<Long>, memoryAvailable long, maxIncomingBatchSize long, initialPartitions int, probeEmpty boolean, buildSizePredictor BatchSizePredictor, probeSizePredictor BatchSizePredictor, recordsPerPartitionBatchBuild int, recordsPerPartitionBatchProbe int, maxBatchNumRecordsBuild int, maxBatchNumRecordsProbe int, outputBatchSize int, loadFactor double) : void in class org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculatorImpl.BuildSidePartitioningImpl |
From |
To |
|
Rename Parameter probeSideBatch : RecordBatch to probeBatch : RecordBatch in method public initialize(autoTune boolean, reserveHash boolean, buildBatch RecordBatch, probeBatch RecordBatch, joinColumns Set<String>, probeEmpty boolean, memoryAvailable long, maxIncomingBatchSize long, initialPartitions int, recordsPerPartitionBatchBuild int, recordsPerPartitionBatchProbe int, maxBatchNumRecordsBuild int, maxBatchNumRecordsProbe int, outputBatchSize int, loadFactor double) : void in class org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculatorImpl.BuildSidePartitioningImpl |
From |
To |
|
Rename Parameter buildNumRecords : int to buildSizePredictor : BatchSizePredictor in method protected initialize(autoTune boolean, reserveHash boolean, keySizes CaseInsensitiveMap<Long>, memoryAvailable long, maxIncomingBatchSize long, initialPartitions int, probeEmpty boolean, buildSizePredictor BatchSizePredictor, probeSizePredictor BatchSizePredictor, recordsPerPartitionBatchBuild int, recordsPerPartitionBatchProbe int, maxBatchNumRecordsBuild int, maxBatchNumRecordsProbe int, outputBatchSize int, loadFactor double) : void in class org.apache.drill.exec.physical.impl.join.HashJoinMemoryCalculatorImpl.BuildSidePartitioningImpl |
From |
To |