cluster-bootstrap-api/src/main/java/com/streamsets/pipeline/spark/SparkStreamingBinding.java
CheckpointPath getCheckPointPath(String topic, String consumerGroup) {
    return new CheckpointPath.Builder(CHECKPOINT_BASE_DIR)
        .sdcId(Utils.getPropertyNotNull(properties, SDC_ID))
        .topic(topic)
        .consumerGroup(consumerGroup)
        .pipelineName(Utils.getPropertyNotNull(properties, ClusterModeConstants.CLUSTER_PIPELINE_NAME))
        .build();
  }
CheckpointPath getCheckPointPath(String topic, String consumerGroup) {
    return new CheckpointPath.Builder(CHECKPOINT_BASE_DIR)
        .sdcId(Utils.getPropertyNotNull(properties, SDC_ID))
        .topic(topic)
        .consumerGroup(consumerGroup)
        .pipelineName(Utils.getPropertyNotNull(properties, ClusterModeConstants.CLUSTER_PIPELINE_NAME))
        .build();
  }
Visible For Testing (TODO - Import guava and make sure it doesn't conflict with spark's rootclassloader)