private static synchronized void createPartition()

in src/main/java/com/aliyun/odps/kafka/connect/MaxComputeSinkWriter.java [484:496]

11 lines of code
2 McCabe index (conditional complexity)


  private static synchronized void createPartition(
      Odps odps,
      String project,
      String table,
      PartitionSpec partitionSpec)
      throws OdpsException {
    Table t = odps.tables().get(project, table);
    // Check the existence of the partition before executing a DML. Could save a lot of time.
    if (!t.hasPartition(partitionSpec)) {
      // Add if not exists to avoid conflicts
      t.createPartition(partitionSpec, true);
    }
  }