Method testSplitsEligibleRollupQuery

test/core/TestTSQuery.java:638–656

()

  }

  @Test
  public void testSplitsEligibleRollupQuery() throws Exception {
    final TSQuery queryUnderTest = getMetricForValidate();

    TSDB tsdb = PowerMockito.mock(TSDB.class);
    TsdbQuery mockTsdbQuery = PowerMockito.mock(TsdbQuery.class);
    when(mockTsdbQuery.configureFromQuery(eq(queryUnderTest), anyInt())).thenReturn(Deferred.fromResult(null));
    when(mockTsdbQuery.needsSplitting()).thenReturn(true);
    when(tsdb.newQuery()).thenReturn(mockTsdbQuery);

    SplitRollupQuery mockSplitQuery = PowerMockito.mock(SplitRollupQuery.class);
    when(mockSplitQuery.configureFromQuery(eq(queryUnderTest), anyInt())).thenReturn(Deferred.fromResult(null));

    PowerMockito.whenNew(SplitRollupQuery.class).withAnyArguments().thenReturn(mockSplitQuery);

    queryUnderTest.buildQueriesAsync(tsdb);

    verify(mockSplitQuery).configureFromQuery(queryUnderTest, 0);
  }

  @Test
  public void testDoesNotSplitIneligibleRollupQuery() {