private String getPendingFileName()

in hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/v2/InstantFileNameGeneratorV2.java [210:283]
74 lines of code
35 McCabe index (conditional complexity)

  private String getPendingFileName(HoodieInstant instant) {
    String action = instant.getAction();
    String timestamp = instant.requestedTime();
    if (HoodieTimeline.COMMIT_ACTION.equals(action)) {
      if (instant.isInflight()) {
        return makeInflightCommitFileName(timestamp);
      } else if (instant.isRequested()) {
        return makeRequestedCommitFileName(timestamp);
      }
    } else if (HoodieTimeline.CLEAN_ACTION.equals(action)) {
      if (instant.isInflight()) {
        return makeInflightCleanerFileName(timestamp);
      } else if (instant.isRequested()) {
        return makeRequestedCleanerFileName(timestamp);
      }
    } else if (HoodieTimeline.ROLLBACK_ACTION.equals(action)) {
      if (instant.isInflight()) {
        return makeInflightRollbackFileName(timestamp);
      } else if (instant.isRequested()) {
        return makeRequestedRollbackFileName(timestamp);
      }
    } else if (HoodieTimeline.SAVEPOINT_ACTION.equals(action)) {
      return makeInflightSavePointFileName(timestamp);
    } else if (HoodieTimeline.DELTA_COMMIT_ACTION.equals(action)) {
      if (instant.isInflight()) {
        return makeInflightDeltaFileName(timestamp);
      } else if (instant.isRequested()) {
        return makeRequestedDeltaFileName(timestamp);
      }
    } else if (HoodieTimeline.COMPACTION_ACTION.equals(action)) {
      if (instant.isInflight()) {
        return makeInflightCompactionFileName(timestamp);
      } else if (instant.isRequested()) {
        return makeRequestedCompactionFileName(timestamp);
      }
    } else if (HoodieTimeline.LOG_COMPACTION_ACTION.equals(action)) {
      if (instant.isInflight()) {
        return makeInflightLogCompactionFileName(timestamp);
      } else if (instant.isRequested()) {
        return makeRequestedLogCompactionFileName(timestamp);
      }
    } else if (HoodieTimeline.RESTORE_ACTION.equals(action)) {
      if (instant.isInflight()) {
        return makeInflightRestoreFileName(timestamp);
      } else if (instant.isRequested()) {
        return makeRequestedRestoreFileName(timestamp);
      }
    } else if (HoodieTimeline.REPLACE_COMMIT_ACTION.equals(action)) {
      if (instant.isInflight()) {
        return makeInflightReplaceFileName(timestamp);
      } else if (instant.isRequested()) {
        return makeRequestedReplaceFileName(timestamp);
      }
    } else if (HoodieTimeline.CLUSTERING_ACTION.equals(action)) {
      if (instant.isInflight()) {
        return makeInflightClusteringFileName(timestamp);
      } else if (instant.isRequested()) {
        return makeRequestedClusteringFileName(timestamp);
      }
    } else if (HoodieTimeline.INDEXING_ACTION.equals(action)) {
      if (instant.isInflight()) {
        return makeInflightIndexFileName(timestamp);
      } else if (instant.isRequested()) {
        return makeRequestedIndexFileName(timestamp);
      }
    } else if (HoodieTimeline.SCHEMA_COMMIT_ACTION.equals(action)) {
      if (instant.isInflight()) {
        return makeInflightSchemaFileName(timestamp);
      } else if (instant.isRequested()) {
        return makeRequestSchemaFileName(timestamp);
      }
    }
    throw new IllegalArgumentException("Cannot get file name for unknown action " + action);
  }