private void validateRequests()

in java/clickhouse-connector/src/main/java/com/epam/deltix/timebase/connector/clickhouse/services/ReplicatorService.java [208:231]

• 24 lines of code
• 9 McCabe index (conditional complexity)

    private void validateRequests(List<QueryRequest> queries, List<StreamRequest> streamRequests) {
        List<String> allTargetTables = new ArrayList<>();
        for (StreamRequest streamRequest : streamRequests) {
            RecordClassSet recordClassSet = tryGetSchema(streamRequest);
            if (streamRequest.getTypeTableMapping() != null && !streamRequest.getTypeTableMapping().isEmpty()) {
                allTargetTables.addAll(streamRequest.getTypeTableMapping().values());
            } else if (streamRequest.isSplitByTypes()) {
                allTargetTables.addAll(getSplitTables(recordClassSet));
            } else {
                allTargetTables.add(streamRequest.getTable());
            }
        }
        for (QueryRequest queryRequest : queries) {
            RecordClassSet recordClassSet = tryGetSchema(queryRequest);
            if (queryRequest.getTypeTableMapping() != null && !queryRequest.getTypeTableMapping().isEmpty()) {
                allTargetTables.addAll(queryRequest.getTypeTableMapping().values());
            } else if (queryRequest.isSplitByTypes()) {
                allTargetTables.addAll(getSplitTables(recordClassSet));
            } else {
                allTargetTables.add(queryRequest.getTable());
            }
        }
        validateTargetTables(allTargetTables);
    }