Examples of TransportClient

com.linkedin.r2.transport.common.bridge.client.TransportClient
@author Chris Pettitt @version $Revision$
org.apache.spark.network.client.TransportClient
Client for fetching consecutive chunks of a pre-negotiated stream. This API is intended to allow efficient transfer of a large amount of data, broken up into chunks with size ranging from hundreds of KB to a few MB. Note that while this client deals with the fetching of chunks from a stream (i.e., data plane), the actual setup of the streams is done outside the scope of the transport layer. The convenience method "sendRPC" is provided to enable control plane communication between the client and server to perform this setup. For example, a typical workflow might be: client.sendRPC(new OpenFile("/foo")) --> returns StreamId = 100 client.fetchChunk(streamId = 100, chunkIndex = 0, callback) client.fetchChunk(streamId = 100, chunkIndex = 1, callback) ... client.sendRPC(new CloseStream(100)) Construct an instance of TransportClient using {@link TransportClientFactory}. A single TransportClient may be used for multiple streams, but any given stream must be restricted to a single client, in order to avoid out-of-order responses. NB: This class is used to make requests to the server, while {@link TransportResponseHandler} isresponsible for handling responses from the server. Concurrency: thread safe and can be called from multiple threads.
org.elasticsearch.client.transport.TransportClient
The transport client allows to create a client that is not part of the cluster, but simply connects to one or more nodes directly by adding their respective addresses using {@link #addTransportAddress(org.elasticsearch.common.transport.TransportAddress)}.
The transport client important modules used is the {@link org.elasticsearch.transport.TransportModule} which isstarted in client mode (only connects, no bind). @author kimchy (shay.banon)

Examples of org.elasticsearch.client.transport.TransportClient

      throw new NullPointerException("transportClientSettings");
    }
    if (index == null) {
      throw new NullPointerException("index");
    }
    _client = new TransportClient(transportClientSettings);
    _index = index;
  }

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient

    port = job.getInt(ElasticConstants.PORT, -1);
    
    // Prefer TransportClient
    if (host != null && port > 1) {
      Settings settings = ImmutableSettings.settingsBuilder().put("cluster.name", clusterName).build();
      client = new TransportClient(settings).addTransportAddress(new InetSocketTransportAddress(host, port));
    } else if (clusterName != null) {
      node = nodeBuilder().clusterName(clusterName).client(true).node();
      client = node.client();
    }

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient

        Logger.getLogger("test").info("querying " + searchHost + ":" + searchPort
                + " at " + searchIndexName + " with " + basicAuthCredentials);


        Settings settings = ImmutableSettings.settingsBuilder()
                .put("cluster.name", cluster).build();
        Client client = new TransportClient(settings).
                addTransportAddress(new InetSocketTransportAddress(searchHost, searchPort));


        Settings emptySettings = ImmutableSettings.settingsBuilder().build();
        RestController contrl = new RestController(emptySettings);
        ReIndexAction action = new ReIndexAction(emptySettings, client, contrl) {

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient

  public void afterPropertiesSet() throws Exception {
    internalCreateTransportClient();
  }


  private void internalCreateTransportClient() {
    final TransportClient client = new TransportClient();


    if (null != transportAddresses) {
      for (final Entry<String, Integer> address : transportAddresses.entrySet()) {
        if (logger.isInfoEnabled()) {
          logger.info("Adding transport address: " + address.getKey() + " port: "
              + address.getValue());
        }
        client.addTransportAddress(new InetSocketTransportAddress(address.getKey(),
            address.getValue()));
      }
    }


  }

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient

        client = createClient(ElasticNode.CLUSTER, url, port);
    }


    public static Client createClient(String cluster, String url, int port) {
        Settings s = ImmutableSettings.settingsBuilder().put("cluster.name", cluster).build();
        TransportClient tmp = new TransportClient(s);
        tmp.addTransportAddress(new InetSocketTransportAddress(url, port));
        return tmp;
    }

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient


    Builder globalSettings = ImmutableSettings.settingsBuilder();
    Settings snode = globalSettings.put("cluster.name", _clusterName).build();
    
    Client client = null;
    TransportClient tmp = null;
    try {
      tmp = new TransportClient(snode);
      client = tmp.addTransportAddress(new InetSocketTransportAddress(sHostname, Integer.parseInt(sPort)));
    
      if (!IndexExistsUtils.exists(client.admin().indices(), indexName)) {
        return false;
      }
      client.admin().cluster().health(new ClusterHealthRequest(indexName).waitForYellowStatus()).actionGet();
    }
    catch (Exception e) { // Index not alive...
      return false;
    }
    finally {
      if (null != client) {
        client.close(); // (will also close tmp)
      }
      else if (null != tmp) {
        tmp.close();
      }
    }
    return true;
  }

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient

        sHostname = hostPort[0];
        sPort = hostPort[1];


        Builder globalSettings = ImmutableSettings.settingsBuilder();
        Settings snode = globalSettings.put("cluster.name", _clusterName).build();
        TransportClient tmp = new TransportClient(snode);
        _elasticClient = new CrossVersionClient(tmp.addTransportAddress(new InetSocketTransportAddress(sHostname, Integer.parseInt(sPort))));
      }
      
    } //TESTED
    else { // Create a "no data" cluster

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient

        sHostname = hostPort[0];
        sPort = hostPort[1];
  
        Builder globalSettings = ImmutableSettings.settingsBuilder();
        Settings snode = globalSettings.put("cluster.name", _clusterName).build();
        TransportClient tmp = new TransportClient(snode);
        _elasticClient = new CrossVersionClient(tmp.addTransportAddress(new InetSocketTransportAddress(sHostname, Integer.parseInt(sPort))));
      }
      
    } //TESTED
    else { // Create a "no data" cluster

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient

        client = createClient(ElasticNode.CLUSTER, url, ElasticNode.PORT);
    }


    public static Client createClient(String cluster, String url, int port) {
        Settings s = ImmutableSettings.settingsBuilder().put("cluster.name", cluster).build();
        TransportClient tmp = new TransportClient(s);
        tmp.addTransportAddress(new InetSocketTransportAddress(url, port));
        return tmp;
    }

View Full Code Here

Examples of org.elasticsearch.client.transport.TransportClient

        List<String> hosts = config.getListProperty(ElasticIOConfig.ELASTICSEARCH_HOSTS);
        String clusterName = config.getStringProperty(ElasticIOConfig.ELASTICSEARCH_CLUSTERNAME);
        Settings settings = ImmutableSettings.settingsBuilder()
                .put("cluster.name", clusterName)
                .build();
        TransportClient tc = new TransportClient(settings);
        for (String host : hosts) {
            String[] parts = host.split(":");
            String address = parts[0];
            Integer port = Integer.parseInt(parts[1]);
            tc.addTransportAddress(new InetSocketTransportAddress(address, port));
        }
        client = tc;
    }

View Full Code Here

0 1 2 3 4 5

TOP

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.