public QueryBuilder withParallelizationCondition()

in dbeam-core/src/main/java/com/spotify/dbeam/args/QueryBuilder.java [161:175]

• 15 lines of code
• 1 McCabe index (conditional complexity)

  public QueryBuilder withParallelizationCondition(
      final String partitionColumn,
      final long startPointIncl,
      final long endPoint,
      final boolean isEndPointExcl) {
    return new QueryBuilder(
        this.base,
        Stream.concat(
                this.whereConditions.stream(),
                Stream.of(
                    createSqlSplitCondition(
                        partitionColumn, startPointIncl, endPoint, isEndPointExcl)))
            .collect(Collectors.toList()),
        this.limitStr);
  }