public boolean startDistRaid ( ) throws IOException { assert ( raidPolicyPathPairList . size ( ) > 0 ) ; if ( setup ( ) ) { this . jobClient = new JobClient ( jobconf ) ; this . runningJob = this . jobClient . submitJob ( jobconf ) ; LOG . info ( "Job Started: " + runningJob . getID ( ) ) ; this . startTime = System . currentTimeMillis ( ) ; return true ; } return false ; }
Invokes a map - reduce job do parallel raiding .