public static List nimbusClientandConn(String host, Integer port) throws TTransportException { TSocket ts = new TSocket(host, port); TFramedTransport tt = new TFramedTransport(ts); TBinaryProtocol prot = new TBinaryProtocol(tt); Client nc = new Client(prot); ts.open(); List l = new ArrayList(); l.add(nc); l.add(tt); return l; }
/** * Connect to the specified server via framed transport * * @param transport * The underlying Thrift transport. */ @Override public TTransport connect(TTransport transport, String serverHost) throws TTransportException { // create a framed transport TTransport conn = new TFramedTransport(transport); // connect conn.open(); LOG.debug("Simple client transport has been established"); return conn; }
private void connect() throws TException { TSocket socket = new TSocket(host, port); if (timeout != null) { socket.setTimeout(timeout); } conn = new TFramedTransport(socket); client = new DistributedRPC.Client(new TBinaryProtocol(conn)); conn.open(); }
/** * Connect to the specified server via framed transport * @param transport The underlying Thrift transport. */ public TTransport connect(TTransport transport, String serverHost) throws TTransportException { //create a framed transport TTransport conn = new TFramedTransport(transport); //connect conn.open(); LOG.debug("Simple client transport has been established"); return conn; }
/** * Connect to the specified server via framed transport * * @param transport * The underlying Thrift transport. */ public TTransport connect(TTransport transport, String serverHost) throws TTransportException { // create a framed transport TTransport conn = new TFramedTransport(transport); // connect conn.open(); LOG.debug("Simple client transport has been established"); return conn; }
/** * Creates a connection with explicit nimbus host. Ignored if a local cluster is set * for testing. * * @param nimbusHost the nimbus host name * @param port the nimbus port number * @see #setLocalCluster(ILocalCluster) */ public ThriftConnection(String nimbusHost, int port) { if (null == localCluster) { socket = new TSocket(nimbusHost, port); LOGGER.info("Thrift connection info " + nimbusHost + " " + port); transport = new TFramedTransport(socket); protocol = new TBinaryProtocol(transport); client = new Client(protocol); } }
public KestrelThriftClient(String hostname, int port) throws TException { _transport = new TFramedTransport(new TSocket(hostname, port)); final TProtocol proto = new TBinaryProtocol(_transport); _client = new Kestrel.Client(proto); _transport.open(); }
private void connect() throws TException { conn = new TFramedTransport(new TSocket(host, port)); client = new DistributedRPCInvocations.Client(new TBinaryProtocol(conn)); conn.open(); }