Examples of org.elasticsearch.node.NodeBuilder

org.elasticsearch.node.NodeBuilder
A node builder is used to construct a {@link Node} instance.
Settings will be loaded relative to the ES home (with or without config/ prefix) and if not found, within the classpath (with or without config/ prefix). The settings file loaded can either be named elasticsearch.yml or elasticsearch.json). Loading settings can be disabled by calling {@link #loadConfigSettings(boolean)} with false.
Explicit settings can be passed by using the {@link #settings(Settings)} method.
In any case, settings will be resolved from system properties as well that are either prefixed with es. or elasticsearch..
An example for creating a simple node with optional settings loaded from the classpath:
```
 Node node = NodeBuilder.nodeBuilder().node(); 
```
An example for creating a node with explicit settings (in this case, a node in the cluster that does not hold data): Node node = NodeBuilder.nodeBuilder() .settings(ImmutableSettings.settingsBuilder().put("node.data", false) .node(); When done with the node, make sure you call {@link Node#close()} on it. @author kimchy (shay.banon)

29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 private String clusterName = "es-out-stage-it-cluster"; @Before public void setup() { NodeBuilder nodeBuilder = NodeBuilder.nodeBuilder() .client(false) .clusterName(clusterName) .loadConfigSettings(false) .local(true); nodeBuilder.settings().put("path.data", dataDir.getRoot().getAbsolutePath()); node = nodeBuilder.build(); node.start(); client = node.client(); stage = new ElasticsearchOutputStage(); stage.setClient(client); View Full Code Here 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 public static boolean createIndex(String appid) { if (StringUtils.isBlank(appid) || StringUtils.containsWhitespace(appid) || existsIndex(appid)) { return false; } try { NodeBuilder nb = NodeBuilder.nodeBuilder(); nb.settings().put("number_of_shards", Config.getConfigParam("para.es.shards", "5")); nb.settings().put("number_of_replicas", Config.getConfigParam("para.es.replicas", "0")); nb.settings().put("auto_expand_replicas", "0-all"); nb.settings().put("analysis.analyzer.default.type", "standard"); nb.settings().putArray("analysis.analyzer.default.stopwords", "arabic", "armenian", "basque", "brazilian", "bulgarian", "catalan", "czech", "danish", "dutch", "english", "finnish", "french", "galician", "german", "greek", "hindi", "hungarian", "indonesian", "italian", "norwegian", "persian", "portuguese", "romanian", "russian", "spanish", "swedish", "turkish"); String name = appid + "1"; CreateIndexRequestBuilder create = getClient().admin().indices().prepareCreate(name). setSettings(nb.settings().build()); // default system mapping (all the rest are dynamic) create.addMapping("_default_", getDefaultMapping()); create.execute().actionGet(); View Full Code Here 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 public static boolean createIndex(String appid, int shards, int replicas) { if (StringUtils.isBlank(appid) || StringUtils.containsWhitespace(appid) || existsIndex(appid)) { return false; } try { NodeBuilder nb = NodeBuilder.nodeBuilder(); nb.settings().put("number_of_shards", Integer.toString(shards)); nb.settings().put("number_of_replicas", Integer.toString(replicas)); nb.settings().put("auto_expand_replicas", "0-all"); nb.settings().put("analysis.analyzer.default.type", "standard"); nb.settings().putArray("analysis.analyzer.default.stopwords", "arabic", "armenian", "basque", "brazilian", "bulgarian", "catalan", "czech", "danish", "dutch", "english", "finnish", "french", "galician", "german", "greek", "hindi", "hungarian", "indonesian", "italian", "norwegian", "persian", "portuguese", "romanian", "russian", "spanish", "swedish", "turkish"); String name = appid + "1"; CreateIndexRequestBuilder create = getClient().admin().indices().prepareCreate(name). setSettings(nb.settings().build()); // default system mapping (all the rest are dynamic) create.addMapping("_default_", getDefaultMapping()); create.execute().actionGet(); View Full Code Here 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 if (!config.containsKey(GraphDatabaseConfiguration.HOSTNAME_KEY)) { boolean clientOnly = config.getBoolean(CLIENT_ONLY_KEY, CLIENT_ONLY_DEFAULT); boolean local = config.getBoolean(LOCAL_MODE_KEY, LOCAL_MODE_DEFAULT); NodeBuilder builder = NodeBuilder.nodeBuilder(); Preconditions.checkArgument(config.containsKey(ES_YML_KEY) || config.containsKey(GraphDatabaseConfiguration.STORAGE_DIRECTORY_KEY), "Must either configure configuration file or base directory"); if (config.containsKey(ES_YML_KEY)) { String configFile = config.getString(ES_YML_KEY); log.debug("Configuring ES from YML file [{}]", configFile); Settings settings = ImmutableSettings.settingsBuilder().loadFromSource(configFile).build(); builder.settings(settings); } else { String dataDirectory = config.getString(GraphDatabaseConfiguration.STORAGE_DIRECTORY_KEY); log.debug("Configuring ES with data directory [{}]", dataDirectory); File f = new File(dataDirectory); if (!f.exists()) f.mkdirs(); ImmutableSettings.Builder b = ImmutableSettings.settingsBuilder(); for (String sub : DATA_SUBDIRS) { String subdir = dataDirectory + File.separator + sub; f = new File(subdir); if (!f.exists()) f.mkdirs(); b.put("path." + sub, subdir); } builder.settings(b.build()); String clustername = config.getString(CLUSTER_NAME_KEY, CLUSTER_NAME_DEFAULT); Preconditions.checkArgument(StringUtils.isNotBlank(clustername), "Invalid cluster name: %s", clustername); builder.clusterName(clustername); } node = builder.client(clientOnly).data(!clientOnly).local(local).node(); client = node.client(); } else { ImmutableSettings.Builder settings = ImmutableSettings.settingsBuilder(); if (config.containsKey(CLUSTER_NAME_KEY)) { View Full Code Here 57 58 59 60 61 62 63 64 65 { if (!checkIfServerRunning()) { ImmutableSettings.Builder builder = ImmutableSettings.settingsBuilder(); builder.put("path.data", "target/data"); node = new NodeBuilder().settings(builder).node(); } emf = getEntityManagerFactory(); } View Full Code Here 195 196 197 198 199 200 201 202 203 204 205 public void onInsertLuceneHbase() throws Exception { // enabled for es indexing. ImmutableSettings.Builder builder = ImmutableSettings.settingsBuilder(); builder.put("path.data", "target/data"); Node node = new NodeBuilder().settings(builder).node(); // Map<String, Object> puProperties = new HashMap<String, Object>(); puProperties.put("kundera.indexer.class", "com.impetus.client.es.index.ESIndexer"); // puProperties.put("index.home.dir", "./lucene"); // uncomment for // lucene View Full Code Here 53 54 55 56 57 58 59 @BeforeClass public static void setUpBeforeClass() throws Exception { ImmutableSettings.Builder builder = ImmutableSettings.settingsBuilder(); builder.put("path.data", "target/data"); node = new NodeBuilder().settings(builder).node(); } View Full Code Here 49 50 51 52 53 54 55 @BeforeClass public static void setUpBeforeClass() throws Exception { ImmutableSettings.Builder builder = ImmutableSettings.settingsBuilder(); builder.put("path.data", "target/data"); node = new NodeBuilder().settings(builder).node(); } View Full Code Here 55 56 57 58 59 60 61 @BeforeClass public static void setUpBeforeClass() throws Exception { ImmutableSettings.Builder builder = ImmutableSettings.settingsBuilder(); builder.put("path.data", "target/data"); node = new NodeBuilder().settings(builder).node(); } View Full Code Here 49 50 51 52 53 54 55 @BeforeClass public static void setUpBeforeClass() throws Exception { ImmutableSettings.Builder builder = ImmutableSettings.settingsBuilder(); builder.put("path.data", "target/data"); node = new NodeBuilder().settings(builder).node(); } View Full Code Here 0 1 2 3 TOP Related Classes of org.elasticsearch.node.NodeBuilder ch.entwine.weblounge.search.impl.SearchIndexImpl com.codetroopers.play.elasticsearch.IndexClient com.erudika.para.search.ElasticSearchUtils com.findwise.hydra.output.elasticsearch.ElasticsearchOutputStageIT com.github.cleverage.elasticsearch.IndexClient com.ikanow.infinit.e.data_model.index.ElasticSearchManager com.impetus.client.es.association.ESAssociationTest com.impetus.client.es.association.ManyToManyAssociationTest com.impetus.client.es.ESClientTest com.impetus.client.es.mappedsuperclass.ESMappedSuperClassTest Copyright © 2018 www.massapicom. 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.