Package org.apache.thrift.transport

Examples of org.apache.thrift.transport.TTransport.open()

101
102
103
104
105
106
107
108
109
110
111
        TTransport transport = new TSocket(host, port);
        TProtocol protocol = new TBinaryProtocol(transport, true, true);
        Hbase.Client client = new Hbase.Client(protocol);

        transport.open();

        byte[] t = bytes("demo_table");

        //
        // Scan all tables, look for the demo table and delete it.
View Full Code Here
184
185
186
187
188
189
190
191
192
193
194
    private static Cassandra.Client createConnection(String host, Integer port, boolean framed) throws TTransportException
    {
        TSocket socket = new TSocket(host, port);
        TTransport trans = framed ? new TFramedTransport(socket) : socket;
        trans.open();
        TProtocol protocol = new TBinaryProtocol(trans);

        return new Cassandra.Client(protocol);
    }
}
View Full Code Here
382
383
384
385
386
387
388
389
390
391
392
        TTransport transport = (isUnframed()) ? socket : new TFramedTransport(socket);
        Cassandra.Client client = new Cassandra.Client(new TBinaryProtocol(transport));

        try
        {
            transport.open();

            if (setKeyspace)
            {
                client.set_keyspace("Keyspace1");
            }
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
   * @throws TTransportException Connection errors
   */
  public static ThriftHiveMetastore.Iface create(String host, int port,
    int timeoutMillis) throws TTransportException {
    TTransport transport = new TSocket(host, port, timeoutMillis);
    transport.open();
    TProtocol protocol = new TBinaryProtocol(transport);
    return new ThriftHiveMetastore.Client(protocol);
  }

  /**
 
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
      TTransport transport;
      try {
        transport = new TSocket(host, port);
        TProtocol protocol = new TBinaryProtocol(transport);
        Client client = new Client(protocol);
        transport.open();
        client.append(evt);
        transport.close();
      } catch (TTransportException e) {
        e.printStackTrace();
      } catch (TException e) {
View Full Code Here
707
708
709
710
711
712
713
714
715
716
717
        CassandraClient client = new CassandraClient(new TBinaryProtocol(transport));

        try
        {
            if(!transport.isOpen())
                transport.open();

            if (enable_cql)
                client.set_cql_version(cqlVersion);

            if (setKeyspace)
View Full Code Here
68
69
70
71
72
73
74
75
76
77
78
        "client already initialized -- double init not allowed");
    int timeout = FlumeConfiguration.get().getThriftSocketTimeoutMs();
    TTransport masterTransport = new TSocket(masterHostname, masterPort, timeout);
    TProtocol protocol = new TBinaryProtocol(masterTransport);
    try {
      masterTransport.open();
    } catch (TTransportException e) {
      throw new IOException(e.getMessage());
    }
    masterClient = new Client(protocol);
    LOG.info("Connected to master at " + masterHostname + ":" + masterPort);
View Full Code Here
852
853
854
855
856
857
858
859
860
861
862
  private ThriftFlumeReportServer.Client connectReportClient(String host,
      int port) throws TTransportException {
    TTransport masterTransport = new TSocket(host, port);
    TProtocol protocol = new TBinaryProtocol(masterTransport);
    masterTransport.open();
    return new ThriftFlumeReportServer.Client(protocol);
  }

  protected void connect(String host, int aPort, int rPort) throws IOException,
      TTransportException {
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
  @Test
  public void testGetAllReports() throws TException {
    TTransport transport = new TSocket("localhost", PORT);
    TProtocol protocol = new TBinaryProtocol(transport);
    transport.open();

    ThriftFlumeReportServer.Client client = new ThriftFlumeReportServer.Client(
        protocol);
    Map<String, ThriftFlumeReport> ret = client.getAllReports();
    assertTrue(ret.size() == 1);
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
  @Test
  public void testGetReportByName() throws TException {
    TTransport transport = new TSocket("localhost", PORT);
    TProtocol protocol = new TBinaryProtocol(transport);
    transport.open();
    ThriftFlumeReportServer.Client client = new ThriftFlumeReportServer.Client(
        protocol);

    ThriftFlumeReport rep = client.getReportByName("reportable1");
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.