public void startRTS ( ) throws IOException { List < HubDataSource > dataSources = hubDataStore . getHubDataSources ( ) ; List < String > com = Lists . newArrayList ( ) ; com . add ( getHostPort ( hubDataStore . getHubAddress ( ) ) ) ; com . add ( hubDataStore . getInstanceName ( ) ) ; for ( HubDataSource source : dataSources ) { com . add ( source . getName ( ) ) ; } ExternalProgramExecutor executorService = new ExternalProgramExecutor ( "RTS" , new File ( binLocation , "rts" ) , com . toArray ( new String [ com . size ( ) ] ) ) ; rtsExecutor . add ( executorService ) ; LOG . info ( "Starting RTS : {}" , executorService ) ; executorService . startAndWait ( ) ; }
Starts RTS process .