private PartitionSpec getPartitionSpec()

in src/main/java/com/aliyun/odps/kafka/connect/MaxComputeSinkWriter.java [405:425]

• 19 lines of code
• 4 McCabe index (conditional complexity)

  private PartitionSpec getPartitionSpec(Long timestamp) {
    PartitionSpec partitionSpec = new PartitionSpec();
    ZonedDateTime dt = Instant.ofEpochSecond(timestamp).atZone(tz.toZoneId());
    String datetimeString = dt.format(DATETIME_FORMATTER);

    switch (partitionWindowType) {
      case DAY:
        partitionSpec.set("pt", datetimeString.substring(0, 10));
        break;
      case HOUR:
        partitionSpec.set("pt", datetimeString.substring(0, 13));
        break;
      case MINUTE:
        partitionSpec.set("pt", datetimeString.substring(0, 16));
        break;
      default:
        throw new RuntimeException("Unsupported partition window type");
    }

    return partitionSpec;
  }