class AbstractDataConsistencyChecker implements DataConsistencyChecker {

    @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));
    }

}