private QueryBuilder configurePartitionCondition()

in dbeam-core/src/main/java/com/spotify/dbeam/args/QueryBuilderArgs.java [151:167]

• 16 lines of code
• 2 McCabe index (conditional complexity)

  private QueryBuilder configurePartitionCondition(
      final String partitionColumn,
      final Instant partition,
      final TemporalAmount partitionPeriod,
      final QueryBuilder queryBuilder) {
    if (partitionPeriod() instanceof Period) {
      final LocalDate partitionDate = partition.atZone(ZoneOffset.UTC).toLocalDate();
      final LocalDate nextPartition = partitionDate.plus(partitionPeriod);
      return queryBuilder.withPartitionCondition(
          partitionColumn, partitionDate.toString(), nextPartition.toString());
    } else {
      // in case of sub daily period, use the full timestamp
      final Instant nextPartition = partition.plus(partitionPeriod);
      return queryBuilder.withPartitionCondition(
          partitionColumn, partition.toString(), nextPartition.toString());
    }
  }