sql/src/test/java/org/apache/druid/sql/calcite/BaseCalciteQueryTest.java
/**
   * Reset the walker and conglomerate with required number of merge buffers. Default value is 2.
   */
Reset the walker and conglomerate with required number of merge buffers. Default value is 2.
Reset the walker and conglomerate with required number of merge buffers . Default value is 2 .
protected void requireMergeBuffers(int numMergeBuffers) throws IOException
  {
    conglomerate = QueryStackTests.createQueryRunnerFactoryConglomerate(
        resourceCloser,
        QueryStackTests.getProcessingConfig(true, numMergeBuffers)
    );
    walker = CalciteTests.createMockWalker(conglomerate, temporaryFolder.newFolder());
  }
protected void requireMergeBuffers ( int numMergeBuffers ) throws IOException { conglomerate = QueryStackTests . createQueryRunnerFactoryConglomerate ( resourceCloser , QueryStackTests . getProcessingConfig ( true , numMergeBuffers ) ) ; walker = CalciteTests . createMockWalker ( conglomerate , temporaryFolder . newFolder ( ) ) ; }
Reset the walker and conglomerate with required number of merge buffers.
Reset the walker and conglomerate with required number of merge buffers .