public void modifyDatasetForRecompact ( State recompactState ) { if ( ! this . jobProps ( ) . getPropAsBoolean ( MRCompactor . COMPACTION_RECOMPACT_ALL_DATA , MRCompactor . DEFAULT_COMPACTION_RECOMPACT_ALL_DATA ) ) { this . overwriteInputPath ( this . outputLatePath ) ; this . cleanAdditionalInputPath ( ) ; } else { this . overwriteInputPath ( this . outputPath ) ; this . overwriteInputLatePath ( this . outputLatePath ) ; this . addAdditionalInputPath ( this . outputLatePath ) ; } this . setJobProps ( recompactState ) ; this . resetNeedToRecompact ( ) ; }
Modify an existing dataset to recompact from its ouput path .