private boolean shouldPublishData(DateTime jobStartTime) throws IOException {
    if (this.policy != Policy.DO_PUBLISH_DATA) {
      return false;
    }
    if (!this.dataset.jobProps().getPropAsBoolean(COMPACTION_JOB_ABORT_UPON_NEW_DATA,
        DEFAULT_COMPACTION_JOB_ABORT_UPON_NEW_DATA)) {
      return true;
    }
    for (Path inputPath : getInputPaths()) {
      if (findNewDataSinceCompactionStarted(inputPath, jobStartTime)) {
        return false;
      }
    }
    return true;
  }
private boolean shouldPublishData ( DateTime jobStartTime ) throws IOException { if ( this . policy != Policy . DO_PUBLISH_DATA ) { return false ; } if ( ! this . dataset . jobProps ( ) . getPropAsBoolean ( COMPACTION_JOB_ABORT_UPON_NEW_DATA , DEFAULT_COMPACTION_JOB_ABORT_UPON_NEW_DATA ) ) { return true ; } for ( Path inputPath : getInputPaths ( ) ) { if ( findNewDataSinceCompactionStarted ( inputPath , jobStartTime ) ) { return false ; } } return true ; }
Data should be published if: (1) this.policy == {@link Policy#DO_PUBLISH_DATA}; (2) either
compaction.abort.upon.new.data=false, or no new data is found in the input folder since jobStartTime.