test_class.declarator: GSON = new Gson()
test_class.modifier: private static final
test_class.original_string: private static final Gson GSON = new Gson();
test_class.type: Gson
test_class.var_name: GSON
test_class.declarator: dataConsistencyChecker
test_class.modifier: private
test_class.original_string: private DataConsistencyChecker dataConsistencyChecker;
test_class.type: DataConsistencyChecker
test_class.var_name: dataConsistencyChecker
test_class.declarator: shardingScalingJob
test_class.modifier: private
test_class.original_string: private ShardingScalingJob shardingScalingJob;
test_class.type: ShardingScalingJob
test_class.var_name: shardingScalingJob
test_class.file: shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/check/AbstractDataConsistencyCheckerTest.java
test_class.identifier: AbstractDataConsistencyCheckerTest
test_case.body: @Test
      public void assertCountCheck() {
          initTableData(shardingScalingJob.getSyncConfigurations().get(0).getDumperConfiguration().getDataSourceConfiguration());
          initTableData(shardingScalingJob.getSyncConfigurations().get(0).getImporterConfiguration().getDataSourceConfiguration());
          Map<String, DataConsistencyCheckResult> resultMap = dataConsistencyChecker.countCheck();
          assertTrue(resultMap.get("t1").isCountValid());
          assertThat(resultMap.get("t1").getSourceCount(), is(resultMap.get("t1").getTargetCount()));
      }
test_case.class_method_signature: AbstractDataConsistencyCheckerTest.assertCountCheck()
test_case.full_signature: @Test public void assertCountCheck()
test_case.identifier: assertCountCheck
test_case.invocations: initTableData getDataSourceConfiguration getDumperConfiguration get getSyncConfigurations initTableData getDataSourceConfiguration getImporterConfiguration get getSyncConfigurations countCheck assertTrue isCountValid get assertThat getSourceCount get is getTargetCount get
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void assertCountCheck()
focal_class.declarator: shardingScalingJob
focal_class.modifier: private final
focal_class.original_string: private final ShardingScalingJob shardingScalingJob;
focal_class.type: ShardingScalingJob
focal_class.var_name: shardingScalingJob
focal_class.file: shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/check/AbstractDataConsistencyChecker.java
focal_class.identifier: AbstractDataConsistencyChecker
focal_class.interfaces: implements DataConsistencyChecker
focal_class.class_method_signature: AbstractDataConsistencyChecker.countCheck()
focal_class.full_signature: @Override public Map<String, DataConsistencyCheckResult> countCheck()
focal_class.identifier: countCheck
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Map<String, DataConsistencyCheckResult>
focal_class.signature: Map<String, DataConsistencyCheckResult> countCheck()
focal_class.class_method_signature: AbstractDataConsistencyChecker.countCheck(final String table)
focal_class.full_signature: private DataConsistencyCheckResult countCheck(final String table)
focal_class.identifier: countCheck
focal_class.modifiers: private
focal_class.parameters: (final String table)
focal_class.return: DataConsistencyCheckResult
focal_class.signature: DataConsistencyCheckResult countCheck(final String table)
focal_class.class_method_signature: AbstractDataConsistencyChecker.count(final DataSource dataSource, final String table)
focal_class.full_signature: private long count(final DataSource dataSource, final String table)
focal_class.identifier: count
focal_class.modifiers: private
focal_class.parameters: (final DataSource dataSource, final String table)
focal_class.return: long
focal_class.signature: long count(final DataSource dataSource, final String table)
focal_class.class_method_signature: AbstractDataConsistencyChecker.getSourceDataSource()
focal_class.full_signature: protected DataSourceWrapper getSourceDataSource()
focal_class.identifier: getSourceDataSource
focal_class.modifiers: protected
focal_class.parameters: ()
focal_class.return: DataSourceWrapper
focal_class.signature: DataSourceWrapper getSourceDataSource()
focal_class.class_method_signature: AbstractDataConsistencyChecker.getTargetDataSource()
focal_class.full_signature: protected DataSourceWrapper getTargetDataSource()
focal_class.identifier: getTargetDataSource
focal_class.modifiers: protected
focal_class.parameters: ()
focal_class.return: DataSourceWrapper
focal_class.signature: DataSourceWrapper getTargetDataSource()
focal_class.class_method_signature: AbstractDataConsistencyChecker.getSqlBuilder()
focal_class.full_signature: protected abstract AbstractSQLBuilder getSqlBuilder()
focal_class.identifier: getSqlBuilder
focal_class.modifiers: protected abstract
focal_class.parameters: ()
focal_class.return: AbstractSQLBuilder
focal_class.signature: AbstractSQLBuilder getSqlBuilder()
focal_method.body: @Override
      public Map<String, DataConsistencyCheckResult> countCheck() {
          return shardingScalingJob.getSyncConfigurations()
                  .stream().flatMap(each -> each.getDumperConfiguration().getTableNameMap().values().stream()).collect(Collectors.toSet())
                  .stream().collect(Collectors.toMap(Function.identity(), this::countCheck));
      }
focal_method.class_method_signature: AbstractDataConsistencyChecker.countCheck()
focal_method.full_signature: @Override public Map<String, DataConsistencyCheckResult> countCheck()
focal_method.identifier: countCheck
focal_method.invocations: collect stream collect flatMap stream getSyncConfigurations stream values getTableNameMap getDumperConfiguration toSet toMap identity
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: Map<String, DataConsistencyCheckResult>
focal_method.signature: Map<String, DataConsistencyCheckResult> countCheck()