public void submit ( final String script , final Boolean showHeader ) throws Exception { this . done ( ) ; if ( MapReduceFormat . class . isAssignableFrom ( this . graph . getGraphOutputFormat ( ) ) ) { this . state . assertNotLocked ( ) ; ( ( Class < ? extends MapReduceFormat > ) this . graph . getGraphOutputFormat ( ) ) . getConstructor ( ) . newInstance ( ) . addMapReduceJobs ( this . compiler ) ; } this . compiler . completeSequence ( ) ; ToolRunner . run ( this . compiler , new String [ ] { script , showHeader . toString ( ) } ) ; }
Submit the FaunusPipeline to the Hadoop cluster and ensure that a header is emitted in the logs .