public void startHFTA ( ) throws IOException { int hftaCount = MetaInformationParser . getHFTACount ( new File ( this . hubDataStore . getBinaryLocation ( ) . toURI ( ) ) ) ; for ( int i = 0 ; i < hftaCount ; i ++ ) { List < String > com = Lists . newArrayList ( ) ; com . add ( getHostPort ( hubDataStore . getHubAddress ( ) ) ) ; com . add ( hubDataStore . getInstanceName ( ) ) ; ExternalProgramExecutor executorService = new ExternalProgramExecutor ( "HFTA-" + i , new File ( binLocation , "hfta_" + i ) , com . toArray ( new String [ com . size ( ) ] ) ) ; hftaExecutor . add ( executorService ) ; LOG . info ( "Starting HFTA : {}" , executorService ) ; executorService . startAndWait ( ) ; } }
Starts HFTA processes .