@ Override public TTransport connect ( TTransport transport , String serverHost , String asUser ) throws TTransportException { int maxBufferSize = type . getMaxBufferSize ( storm_conf ) ; // create a framed transport TTransport conn = new TFramedTransport ( transport , maxBufferSize ) ; // connect conn . open ( ) ; LOG . debug ( "Simple client transport has been established" ) ; return conn ; }
Connect to the specified server via framed transport