Package org.elasticsearch.node

Examples of org.elasticsearch.node.NodeBuilder.node()

593
594
595
596
597
598
599
600
601
602
603
        } else if(clientType == ClientType.NODE) {
            log.info("Create a nodeClient, allows transport clients to connect");
            nodeBuilder = nodeBuilder.local(false);
        }

        Node node = nodeBuilder.node();
        log.info("Got node");
        client = node.client();
        log.info("Created new node client");
        return client;
    }
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
    if (null != properties) {
      nodeBuilder.getSettings().put(properties);
    }

    if (logger.isDebugEnabled()) logger.debug("Starting ElasticSearch node...");
    node = nodeBuilder.node();
    logger.info("Node [" + node.settings().get("name") + "] for [" + node.settings().get("cluster.name") + "] cluster started...");
    if (logger.isDebugEnabled()) logger.debug("  - data : " + node.settings().get("path.data"));
    if (logger.isDebugEnabled()) logger.debug("  - logs : " + node.settings().get("path.logs"));

    return node;
View Full Code Here
25
26
27
28
29
30
31
32
33
34
35
        ImmutableSettings.Builder settings = config.loadSettings();
        if (config.isLocalMode()) {
            Logger.info("ElasticSearch : Starting in Local Mode");

            NodeBuilder nb = nodeBuilder().settings(settings).local(true).client(false).data(true);
            node = nb.node();
            Logger.info("ElasticSearch : Started in Local Mode");
        }

        client = JestClientWrapper.jestClient(config);
View Full Code Here
31
32
33
34
35
36
37
38
39
40
41
        // Check Model
        if (this.isLocalMode()) {
            Logger.info("ElasticSearch : Starting in Local Mode");

            NodeBuilder nb = nodeBuilder().settings(settings).local(true).client(false).data(true);
            node = nb.node();
            client = node.client();
            Logger.info("ElasticSearch : Started in Local Mode");
        } else {
            Logger.info("ElasticSearch : Starting in Client Mode");
            TransportClient c = new TransportClient(settings);
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.