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();
  }
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)
Visible For Testing ( TODO - Import guava and make sure it doesn t conflict with spark s rootclassloader )