public static CoronaProxyJobTrackerService . Client getPJTClient ( CoronaConf conf ) throws IOException { InetSocketAddress address = NetUtils . createSocketAddr ( conf . getProxyJobTrackerThriftAddress ( ) ) ; TFramedTransport transport = new TFramedTransport ( new TSocket ( address . getHostName ( ) , address . getPort ( ) ) ) ; CoronaProxyJobTrackerService . Client client = new CoronaProxyJobTrackerService . Client ( new TBinaryProtocol ( transport ) ) ; try { transport . open ( ) ; } catch ( TException e ) { LOG . info ( "Transport Exception: " , e ) ; } return client ; }
Used for getting a client to the CoronaProxyJobTracker