private void startThreads ( Configuration conf , String traceIn , Path ioPath , Path scratchDir , CountDownLatch startFlag ) throws IOException { monitor = createJobMonitor ( ) ; submitter = createJobSubmitter ( monitor , conf . getInt ( GRIDMIX_SUB_THR , Runtime . getRuntime ( ) . availableProcessors ( ) + 1 ) , conf . getInt ( GRIDMIX_QUE_DEP , 5 ) , new FilePool ( conf , ioPath ) ) ; factory = createJobFactory ( submitter , traceIn , scratchDir , conf , startFlag ) ; monitor . start ( ) ; submitter . start ( ) ; factory . start ( ) ; }
Create each component in the pipeline and start it .