test_class.file: shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-merge/src/test/java/org/apache/shardingsphere/sharding/merge/dql/groupby/GroupByStreamMergedResultTest.java
test_class.identifier: GroupByStreamMergedResultTest
test_case.body: @Test
      public void assertNextForResultSetsAllEmpty() throws SQLException {
          ShardingDQLResultMerger resultMerger = new ShardingDQLResultMerger(DatabaseTypes.getActualDatabaseType("MySQL"));
          MergedResult actual = resultMerger.merge(Arrays.asList(createQueryResult(), createQueryResult(), createQueryResult()), createSelectStatementContext(), createSchemaMetaData());
          assertFalse(actual.next());
      }
test_case.class_method_signature: GroupByStreamMergedResultTest.assertNextForResultSetsAllEmpty()
test_case.full_signature: @Test public void assertNextForResultSetsAllEmpty()
test_case.identifier: assertNextForResultSetsAllEmpty
test_case.invocations: getActualDatabaseType merge asList createQueryResult createQueryResult createQueryResult createSelectStatementContext createSchemaMetaData assertFalse next
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void assertNextForResultSetsAllEmpty()
focal_class.declarator: selectStatementContext
focal_class.modifier: private final
focal_class.original_string: private final SelectStatementContext selectStatementContext;
focal_class.type: SelectStatementContext
focal_class.var_name: selectStatementContext
focal_class.declarator: currentRow
focal_class.modifier: private final
focal_class.original_string: private final List<Object> currentRow;
focal_class.type: List<Object>
focal_class.var_name: currentRow
focal_class.declarator: currentGroupByValues
focal_class.modifier: private
focal_class.original_string: private List<?> currentGroupByValues;
focal_class.type: List<?>
focal_class.var_name: currentGroupByValues
focal_class.file: shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-merge/src/main/java/org/apache/shardingsphere/sharding/merge/dql/groupby/GroupByStreamMergedResult.java
focal_class.identifier: GroupByStreamMergedResult
focal_class.class_method_signature: GroupByStreamMergedResult.GroupByStreamMergedResult(final Map<String, Integer> labelAndIndexMap, final List<QueryResult> queryResults,
                                       final SelectStatementContext selectStatementContext, final SchemaMetaData schemaMetaData)
focal_class.full_signature: public  GroupByStreamMergedResult(final Map<String, Integer> labelAndIndexMap, final List<QueryResult> queryResults,
                                       final SelectStatementContext selectStatementContext, final SchemaMetaData schemaMetaData)
focal_class.identifier: GroupByStreamMergedResult
focal_class.modifiers: public
focal_class.parameters: (final Map<String, Integer> labelAndIndexMap, final List<QueryResult> queryResults,
                                       final SelectStatementContext selectStatementContext, final SchemaMetaData schemaMetaData)
focal_class.signature:  GroupByStreamMergedResult(final Map<String, Integer> labelAndIndexMap, final List<QueryResult> queryResults,
                                       final SelectStatementContext selectStatementContext, final SchemaMetaData schemaMetaData)
focal_class.class_method_signature: GroupByStreamMergedResult.next()
focal_class.full_signature: @Override public boolean next()
focal_class.identifier: next
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean next()
focal_class.class_method_signature: GroupByStreamMergedResult.aggregateCurrentGroupByRowAndNext()
focal_class.full_signature: private boolean aggregateCurrentGroupByRowAndNext()
focal_class.identifier: aggregateCurrentGroupByRowAndNext
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean aggregateCurrentGroupByRowAndNext()
focal_class.class_method_signature: GroupByStreamMergedResult.aggregate(final Map<AggregationProjection, AggregationUnit> aggregationUnitMap)
focal_class.full_signature: private void aggregate(final Map<AggregationProjection, AggregationUnit> aggregationUnitMap)
focal_class.identifier: aggregate
focal_class.modifiers: private
focal_class.parameters: (final Map<AggregationProjection, AggregationUnit> aggregationUnitMap)
focal_class.return: void
focal_class.signature: void aggregate(final Map<AggregationProjection, AggregationUnit> aggregationUnitMap)
focal_class.class_method_signature: GroupByStreamMergedResult.cacheCurrentRow()
focal_class.full_signature: private void cacheCurrentRow()
focal_class.identifier: cacheCurrentRow
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void cacheCurrentRow()
focal_class.class_method_signature: GroupByStreamMergedResult.getAggregationValue(final AggregationProjection aggregationProjection)
focal_class.full_signature: private Comparable<?> getAggregationValue(final AggregationProjection aggregationProjection)
focal_class.identifier: getAggregationValue
focal_class.modifiers: private
focal_class.parameters: (final AggregationProjection aggregationProjection)
focal_class.return: Comparable<?>
focal_class.signature: Comparable<?> getAggregationValue(final AggregationProjection aggregationProjection)
focal_class.class_method_signature: GroupByStreamMergedResult.setAggregationValueToCurrentRow(final Map<AggregationProjection, AggregationUnit> aggregationUnitMap)
focal_class.full_signature: private void setAggregationValueToCurrentRow(final Map<AggregationProjection, AggregationUnit> aggregationUnitMap)
focal_class.identifier: setAggregationValueToCurrentRow
focal_class.modifiers: private
focal_class.parameters: (final Map<AggregationProjection, AggregationUnit> aggregationUnitMap)
focal_class.return: void
focal_class.signature: void setAggregationValueToCurrentRow(final Map<AggregationProjection, AggregationUnit> aggregationUnitMap)
focal_class.class_method_signature: GroupByStreamMergedResult.getValue(final int columnIndex, final Class<?> type)
focal_class.full_signature: @Override public Object getValue(final int columnIndex, final Class<?> type)
focal_class.identifier: getValue
focal_class.modifiers: @Override public
focal_class.parameters: (final int columnIndex, final Class<?> type)
focal_class.return: Object
focal_class.signature: Object getValue(final int columnIndex, final Class<?> type)
focal_class.class_method_signature: GroupByStreamMergedResult.getCalendarValue(final int columnIndex, final Class<?> type, final Calendar calendar)
focal_class.full_signature: @Override public Object getCalendarValue(final int columnIndex, final Class<?> type, final Calendar calendar)
focal_class.identifier: getCalendarValue
focal_class.modifiers: @Override public
focal_class.parameters: (final int columnIndex, final Class<?> type, final Calendar calendar)
focal_class.return: Object
focal_class.signature: Object getCalendarValue(final int columnIndex, final Class<?> type, final Calendar calendar)
focal_class.superclass: extends OrderByStreamMergedResult
focal_method.body: @Override
      public boolean next() throws SQLException {
          currentRow.clear();
          if (getOrderByValuesQueue().isEmpty()) {
              return false;
          }
          if (isFirstNext()) {
              super.next();
          }
          if (aggregateCurrentGroupByRowAndNext()) {
              currentGroupByValues = new GroupByValue(getCurrentQueryResult(), selectStatementContext.getGroupByContext().getItems()).getGroupValues();
          }
          return true;
      }
focal_method.class_method_signature: GroupByStreamMergedResult.next()
focal_method.full_signature: @Override public boolean next()
focal_method.identifier: next
focal_method.invocations: clear isEmpty getOrderByValuesQueue isFirstNext next aggregateCurrentGroupByRowAndNext getGroupValues getCurrentQueryResult getItems getGroupByContext
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: boolean
focal_method.signature: boolean next()