@Bean public TransportClient initESClient() throws NumberFormatException, UnknownHostException{ String ip = env.getProperty("spring.es.ip"); String port = env.getProperty("spring.es.port"); String clusterName = env.getProperty("spring.es.cluster_name"); Builder builder = Settings.builder().put("cluster.name", clusterName).put("client.transport.sniff", true); Settings esSettings = builder.build(); TransportClient client = new PreBuiltTransportClient(esSettings); client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(ip), Integer.parseInt(port))); logger.info("ES Client 初始化成功, ip : {}, port : {}, cluster_name : {}", ip, port, clusterName); return client; }
private Settings getSettings(int nodeOrdinal, long nodeSeed, Settings others) { Builder builder = Settings.builder().put(defaultSettings) .put(getRandomNodeSettings(nodeSeed)); Settings settings = nodeConfigurationSource.nodeSettings(nodeOrdinal); if (settings != null) { if (settings.get(ClusterName.CLUSTER_NAME_SETTING.getKey()) != null) { throw new IllegalStateException("Tests must not set a '" + ClusterName.CLUSTER_NAME_SETTING.getKey() + "' as a node setting set '" + ClusterName.CLUSTER_NAME_SETTING.getKey() + "': [" + settings.get(ClusterName.CLUSTER_NAME_SETTING.getKey()) + "]"); } builder.put(settings); } if (others != null) { builder.put(others); } builder.put(ClusterName.CLUSTER_NAME_SETTING.getKey(), clusterName); return builder.build(); }
private int indexRandomNumbers(String analyzer, int shards, boolean dummyDocs) throws Exception { Builder builder = Settings.builder().put(indexSettings()); if (shards > 0) { builder.put(SETTING_NUMBER_OF_SHARDS, shards); } assertAcked(prepareCreate("test") .addMapping( "type1", jsonBuilder().startObject().startObject("type1").startObject("properties").startObject("field1") .field("analyzer", analyzer).field("type", "text").endObject().endObject().endObject().endObject()) .setSettings(builder)); int numDocs = randomIntBetween(100, 150); IndexRequestBuilder[] docs = new IndexRequestBuilder[numDocs]; for (int i = 0; i < numDocs; i++) { docs[i] = client().prepareIndex("test", "type1", String.valueOf(i)).setSource("field1", English.intToEnglish(i)); } indexRandom(true, dummyDocs, docs); ensureGreen(); return numDocs; }
public void testFromSize() throws Exception { Builder settings = Settings.builder(); settings.put(SETTING_NUMBER_OF_SHARDS, 1); settings.put(SETTING_NUMBER_OF_REPLICAS, 0); assertAcked(prepareCreate("test").setSettings(settings)); for(int i=0;i<5;i++) { client().prepareIndex("test", "type", ""+i).setSource("text", "hello world").get(); } refresh(); SearchRequestBuilder request = client().prepareSearch(); request.setQuery(QueryBuilders.termQuery("text", "hello")); request.setFrom(1); request.setSize(4); request.addRescorer(RescoreBuilder.queryRescorer(QueryBuilders.matchAllQuery()), 50); assertEquals(4, request.get().getHits().getHits().length); }
public void testBackwardsCompatibilityEdgeNgramTokenFilter() throws Exception { int iters = scaledRandomIntBetween(20, 100); for (int i = 0; i < iters; i++) { final Index index = new Index("test", "_na_"); final String name = "ngr"; Version v = randomVersion(random()); Builder builder = newAnalysisSettingsBuilder().put("min_gram", 2).put("max_gram", 3); boolean reverse = random().nextBoolean(); if (reverse) { builder.put("side", "back"); } Settings settings = builder.build(); Settings indexSettings = newAnalysisSettingsBuilder().put(IndexMetaData.SETTING_VERSION_CREATED, v.id).build(); Tokenizer tokenizer = new MockTokenizer(); tokenizer.setReader(new StringReader("foo bar")); TokenStream edgeNGramTokenFilter = new EdgeNGramTokenFilterFactory(IndexSettingsModule.newIndexSettings(index, indexSettings), null, name, settings).create(tokenizer); if (reverse) { assertThat(edgeNGramTokenFilter, instanceOf(ReverseStringFilter.class)); } else { assertThat(edgeNGramTokenFilter, instanceOf(EdgeNGramTokenFilter.class)); } } }
public void testCorrectPositionIncrementSetting() throws IOException { Builder builder = Settings.builder().put("index.analysis.filter.my_stop.type", "stop"); if (random().nextBoolean()) { builder.put("index.analysis.filter.my_stop.version", Version.LATEST); } else { // don't specify } builder.put(Environment.PATH_HOME_SETTING.getKey(), createTempDir().toString()); ESTestCase.TestAnalysis analysis = AnalysisTestsHelper.createTestAnalysisFromSettings(builder.build()); TokenFilterFactory tokenFilter = analysis.tokenFilter.get("my_stop"); assertThat(tokenFilter, instanceOf(StopTokenFilterFactory.class)); Tokenizer tokenizer = new WhitespaceTokenizer(); tokenizer.setReader(new StringReader("foo bar")); TokenStream create = tokenFilter.create(tokenizer); assertThat(create, instanceOf(StopFilter.class)); }
public void setUp(final BiConsumer<Integer, Builder> consumer) throws Exception { clusterName = "es-idxproxy-" + System.currentTimeMillis(); // create runner instance runner = new ElasticsearchClusterRunner(); // create ES nodes runner.onBuild((number, settingsBuilder) -> { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.putArray("discovery.zen.ping.unicast.hosts", "127.0.0.1:9301-9310"); consumer.accept(number, settingsBuilder); }).build(newConfigs().clusterName(clusterName).numOfNode(numOfNode) .pluginTypes("org.codelibs.elasticsearch.idxproxy.IndexingProxyPlugin")); // wait for yellow status runner.ensureYellow(); }
public ElasticNamespaceDAO(ElasticDAOConfig config) { try { Builder builder = Settings.builder(); // Check for new hosts within the cluster builder.put(CLIENT_SNIFFING_CONFIG, true); // specify cluster name if (config.getClusterName() != null) { builder.put(CLIENT_CLUSTER_NAME_CONFIG, config.getClusterName()); } Settings settings = builder.build(); // create client elasticClient = new PreBuiltTransportClient(settings); // add hosts for (String elasticHost : config.getHosts()) { elasticClient.addTransportAddress( new InetSocketTransportAddress(InetAddress.getByName(elasticHost), config.getPort())); } } catch (UnknownHostException e) { throw new RuntimeException("Unable to initialize Eleasticsearch client " + e.getLocalizedMessage()); } }
public ElasticVdcDAO(ElasticDAOConfig config) { try { Builder builder = Settings.builder(); // Check for new hosts within the cluster builder.put(CLIENT_SNIFFING_CONFIG, true); // specify cluster name if (config.getClusterName() != null) { builder.put(CLIENT_CLUSTER_NAME_CONFIG, config.getClusterName()); } Settings settings = builder.build(); // create client elasticClient = new PreBuiltTransportClient(settings); // add hosts for (String elasticHost : config.getHosts()) { elasticClient.addTransportAddress( new InetSocketTransportAddress(InetAddress.getByName(elasticHost), config.getPort())); } } catch (UnknownHostException e) { throw new RuntimeException("Unable to initialize Eleasticsearch client " + e.getLocalizedMessage()); } }
@BeforeClass public static void cleanUpOnce() throws Exception { deleteDirectory("target/testcluster/"); clusterName = "es-cl-run-" + System.currentTimeMillis(); // create runner instance runner = new ElasticsearchClusterRunner(); // create ES nodes runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); } }).build( newConfigs() .clusterName("testCluster") .numOfNode(3) .basePath("target/testcluster/") .useLogger()); // wait for green status runner.ensureGreen(); client = runner.client(); }
private Builder applySettings() { Builder settingsBuilder = Settings.builder(); settingsBuilder.put("client.transport.ping_timeout", "15s"); settingsBuilder.put("client.transport.nodes_sampler_interval", "5s"); // YG: to ensure reliable connection & resolve NoNodeAvailableException settingsBuilder.put("client.transport.sniff", true); settingsBuilder.put("network.bind_host", 0); // YG: for supporting ES Auth with ES Shield Optional.ofNullable(config.getElastic().getAuth()) .ifPresent(auth -> settingsBuilder.put("xpack.security.user", String.join(":", auth.getUser(), auth.getPwd()))); if (Objects.nonNull(config.getElastic().getClusterName())) { settingsBuilder.put("cluster.name", config.getElastic().getClusterName()); } else { settingsBuilder.put("client.transport.ignore_cluster_name", true); } return settingsBuilder; }
@Override protected void setUp() throws Exception { clusterName = "es-analyzeapi-" + System.currentTimeMillis(); // create runner instance runner = new ElasticsearchClusterRunner(); // create ES nodes runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.putArray("discovery.zen.ping.unicast.hosts", "localhost:9301-9310"); } }).build(newConfigs().clusterName(clusterName).numOfNode(numOfNode) .pluginTypes("org.codelibs.elasticsearch.analyze.AnalyzeApiPlugin,org.codelibs.elasticsearch.ja.JaPlugin")); // wait for yellow status runner.ensureYellow(); }
@Before public void setUp() throws Exception { clusterName = "es-analysisja-" + System.currentTimeMillis(); runner = new ElasticsearchClusterRunner(); runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.putList("discovery.zen.ping.unicast.hosts", "localhost:9301-9310"); } }).build(newConfigs().clusterName(clusterName).numOfNode(numOfNode) .pluginTypes("org.codelibs.elasticsearch.ja.JaPlugin," + "org.codelibs.elasticsearch.ja.kuromoji.plugin.analysis.kuromoji.AnalysisKuromojiPlugin")); userDictFiles = null; }
@Override protected void setUp() throws Exception { clusterName = "es-langfield-" + System.currentTimeMillis(); // create runner instance runner = new ElasticsearchClusterRunner(); // create ES nodes runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.putList("discovery.zen.ping.unicast.hosts", "localhost:9301-9310"); } }).build(newConfigs().clusterName(clusterName).numOfNode(1).pluginTypes("org.codelibs.elasticsearch.langfield.LangFieldPlugin")); // wait for yellow status runner.ensureYellow(); }
@Before public void setUp() throws Exception { clusterName = "es-kuromojineologd-" + System.currentTimeMillis(); runner = new ElasticsearchClusterRunner(); runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.putList("discovery.zen.ping.unicast.hosts", "localhost:9301-9310"); } }).build(newConfigs().clusterName(clusterName).numOfNode(numOfNode) .pluginTypes("org.codelibs.elasticsearch.kuromoji.neologd.KuromojiNeologdPlugin")); userDictFiles = null; }
@Before public void setUp() throws Exception { clusterName = "es-dynarank-" + System.currentTimeMillis(); runner = new ElasticsearchClusterRunner(); runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("dynarank.cache.clean_interval", "1s"); settingsBuilder.put("script.search", true); settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.putArray("discovery.zen.ping.unicast.hosts", "localhost:9301-9310"); } }).build(newConfigs().numOfNode(1).clusterName(clusterName).pluginTypes( "org.codelibs.elasticsearch.dynarank.DynamicRankingPlugin" + ",org.codelibs.elasticsearch.minhash.MinHashPlugin")); runner.ensureGreen(); }
@Override protected void setUp() throws Exception { clusterName = "es-reindexing-" + System.currentTimeMillis(); // create runner instance runner = new ElasticsearchClusterRunner(); // create ES nodes runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.put("index.number_of_shards", 3); settingsBuilder.put("index.number_of_replicas", 0); settingsBuilder.putArray("discovery.zen.ping.unicast.hosts", "localhost:9301-9310"); settingsBuilder.put("plugin.types", "org.codelibs.elasticsearch.reindex.ReindexingPlugin"); settingsBuilder .put("index.unassigned.node_left.delayed_timeout", "0"); } }).build(newConfigs().numOfNode(1).clusterName(clusterName)); // wait for yellow status runner.ensureYellow(); }
@Override protected void setUp() throws Exception { clusterName = "es-minhash-" + System.currentTimeMillis(); // create runner instance runner = new ElasticsearchClusterRunner(); // create ES nodes runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.putList("discovery.zen.ping.unicast.hosts", "localhost:9301-9310"); } }).build(newConfigs().clusterName(clusterName).numOfNode(1).pluginTypes("org.codelibs.elasticsearch.minhash.MinHashPlugin")); // wait for yellow status runner.ensureYellow(); }
@Override protected void setUp() throws Exception { clusterName = "es-taste-" + System.currentTimeMillis(); // create runner instance runner = new ElasticsearchClusterRunner(); // create ES nodes runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.putArray("discovery.zen.ping.unicast.hosts", "localhost:9301-9305"); settingsBuilder.put("plugin.types", "org.codelibs.elasticsearch.taste.TastePlugin"); } }).build(newConfigs().clusterName(clusterName).numOfNode(1)); // wait for yellow status runner.ensureYellow(); }
@Override protected void setUp() throws Exception { clusterName = "es-cl-run-" + System.currentTimeMillis(); // create runner instance runner = new ElasticsearchClusterRunner(); // create ES nodes runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.putList("discovery.zen.ping.unicast.hosts", "localhost:9301-9305"); } }).build( newConfigs() .clusterName(clusterName) .numOfNode(3)); // wait for yellow status runner.ensureYellow(); }
@BeforeClass public static void setUp() throws IOException { clusterName = "es-dataformat-" + System.currentTimeMillis(); // create runner instance runner = new ElasticsearchClusterRunner(); // create ES nodes runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.putList("discovery.zen.ping.unicast.hosts", "localhost:9301-9310"); } }).build(newConfigs().clusterName(clusterName).numOfNode(1) .pluginTypes("org.codelibs.elasticsearch.df.DataFormatPlugin")); // wait for yellow status runner.ensureYellow(); indexing(); node = runner.node(); }
@Override protected void setUp() throws Exception { // create runner instance clusterName = "es-river-web-" + UUID.randomUUID().toString(); runner = new ElasticsearchClusterRunner(); runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.put("index.number_of_shards", 3); settingsBuilder.put("index.number_of_replicas", 0); settingsBuilder.putArray("discovery.zen.ping.unicast.hosts", "localhost:9301-9310"); settingsBuilder.put("index.unassigned.node_left.delayed_timeout", "0"); settingsBuilder.put("network.host", "0"); } }).build(newConfigs().clusterName(clusterName).numOfNode(numOfNode)); // wait for yellow status runner.ensureYellow(); }
@Override protected void setUp() throws Exception { // create runner instance runner = new ElasticsearchClusterRunner(); // create ES nodes runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.putArray("discovery.zen.ping.unicast.hosts", "localhost:9301-9399"); settingsBuilder.put("plugin.types", "org.codelibs.elasticsearch.sample.SamplePlugin"); } }).build( newConfigs() .clusterName("es-cl-run-" + System.currentTimeMillis()) .numOfNode(3)); // wait for yellow status runner.ensureYellow(); }
public void testSynonyms() throws IOException { Builder builder = Settings.builder() .put(indexSettings()) .put("index.analysis.analyzer.synonym.tokenizer", "whitespace") .putArray("index.analysis.analyzer.synonym.filter", "synonym", "lowercase") .put("index.analysis.filter.synonym.type", "synonym") .putArray("index.analysis.filter.synonym.synonyms", "fast,quick"); assertAcked(prepareCreate("test").setSettings(builder.build()) .addMapping("type1", "field1", "type=text,term_vector=with_positions_offsets,search_analyzer=synonym," + "analyzer=english,index_options=offsets")); ensureGreen(); client().prepareIndex("test", "type1", "0").setSource( "field1", "The quick brown fox jumps over the lazy dog").get(); refresh(); for (String highlighterType : ALL_TYPES) { logger.info("--> highlighting (type=" + highlighterType + ") and searching on field1"); SearchSourceBuilder source = searchSource() .query(matchQuery("field1", "quick brown fox").operator(Operator.AND)) .highlighter( highlight() .field("field1") .order("score") .preTags("<x>") .postTags("</x>") .highlighterType(highlighterType)); SearchResponse searchResponse = client().search(searchRequest("test").source(source)).actionGet(); assertHighlight(searchResponse, 0, "field1", 0, 1, equalTo("The <x>quick</x> <x>brown</x> <x>fox</x> jumps over the lazy dog")); source = searchSource() .query(matchQuery("field1", "fast brown fox").operator(Operator.AND)) .highlighter(highlight().field("field1").order("score").preTags("<x>").postTags("</x>")); searchResponse = client().search(searchRequest("test").source(source)).actionGet(); assertHighlight(searchResponse, 0, "field1", 0, 1, equalTo("The <x>quick</x> <x>brown</x> <x>fox</x> jumps over the lazy dog")); } }
public void testPositionIncrementSetting() throws IOException { Builder builder = Settings.builder().put("index.analysis.filter.my_stop.type", "stop") .put("index.analysis.filter.my_stop.enable_position_increments", false); if (random().nextBoolean()) { builder.put("index.analysis.filter.my_stop.version", "5.0"); } builder.put(Environment.PATH_HOME_SETTING.getKey(), createTempDir().toString()); Settings settings = builder.build(); try { AnalysisTestsHelper.createTestAnalysisFromSettings(settings); fail("Expected IllegalArgumentException"); } catch (IllegalArgumentException e) { assertThat(e.getMessage(), containsString("enable_position_increments is not supported anymore")); } }
/** * This method will create the client instance for elastic search. * @param clusterName String * @param host List<String> * @param port List<Integer> * @return boolean * @throws Exception */ private static boolean createClient(String clusterName, List<String> host, List<Integer> port) throws Exception { Builder builder = Settings.builder(); if (clusterName != null && !"".equals(clusterName)) { builder = builder.put("cluster.name", clusterName); } builder = builder.put("client.transport.sniff", true); builder = builder.put("client.transport.ignore_cluster_name", true); client = new PreBuiltTransportClient(builder.build()); for (int i = 0; i < host.size(); i++) { client.addTransportAddress( new InetSocketTransportAddress(InetAddress.getByName(host.get(i)), ports.get(i))); } return true; }
public ElasticBillingDAO(ElasticDAOConfig config) { try { Builder builder = Settings.builder(); // Check for new hosts within the cluster builder.put(CLIENT_SNIFFING_CONFIG, true); // specify cluster name if( config.getClusterName() != null ) { builder.put(CLIENT_CLUSTER_NAME_CONFIG, config.getClusterName()); } Settings settings = builder.build(); // create client elasticClient = new PreBuiltTransportClient(settings); // add hosts for( String elasticHost : config.getHosts()) { elasticClient.addTransportAddress( new InetSocketTransportAddress(InetAddress.getByName(elasticHost), config.getPort())); } } catch (UnknownHostException e) { throw new RuntimeException("Unable to initialize Eleasticsearch client " + e.getLocalizedMessage() ); } }
@Before public void setUp() throws Exception { clusterName = "es-kuromojineologd-" + System.currentTimeMillis(); runner = new ElasticsearchClusterRunner(); runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.putList("discovery.zen.ping.unicast.hosts", "localhost:9301-9310"); } }).build(newConfigs().clusterName(clusterName).numOfNode(numOfNode) .pluginTypes("org.codelibs.elasticsearch.fess.FessAnalysisPlugin")); }
private void prepareClient() { Builder settingsBuilder = applySettings(); try { TransportAddress ista = new TransportAddress(InetAddress.getByName(config.getElastic().getHost()), config.getElastic().getPort()); client = new PreBuiltXPackTransportClient(settingsBuilder.build()) .addTransportAddress(ista); } catch (UnknownHostException ex) { logger.error(ex.getMessage(), ex); System.exit(-1); } }
@Before public void setUp() throws Exception { clusterName = "es-analysisja-" + System.currentTimeMillis(); runner = new ElasticsearchClusterRunner(); runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.putList("discovery.zen.ping.unicast.hosts", "localhost:9301-9310"); } }).build(newConfigs().clusterName(clusterName).numOfNode(numOfNode).pluginTypes("org.codelibs.elasticsearch.ja.JaPlugin")); }
@Before public void setUp() throws Exception { clusterName = "es-analysisja-" + System.currentTimeMillis(); runner = new ElasticsearchClusterRunner(); runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.putList("discovery.zen.ping.unicast.hosts", "localhost:9301-9310"); } }).build(newConfigs().clusterName(clusterName).numOfNode(numOfNode).pluginTypes("org.codelibs.elasticsearch.ja.JaPlugin")); numberSuffixFiles = null; }
@Before public void setUp() throws Exception { clusterName = "es-analysisja-" + System.currentTimeMillis(); runner = new ElasticsearchClusterRunner(); runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.putList("discovery.zen.ping.unicast.hosts", "localhost:9301-9310"); } }).build(newConfigs().clusterName(clusterName).numOfNode(numOfNode).pluginTypes("org.codelibs.elasticsearch.ja.JaPlugin")); keywordFiles = null; }
@Before public void setUp() throws Exception { clusterName = "es-analysisja-" + System.currentTimeMillis(); runner = new ElasticsearchClusterRunner(); runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.putList("discovery.zen.ping.unicast.hosts", "localhost:9301-9310"); } }).build(newConfigs().clusterName(clusterName).numOfNode(numOfNode).pluginTypes("org.codelibs.elasticsearch.ja.JaPlugin")); stopwordFiles = null; }
private void setupClusterRunnder(final Boolean fileUpdaterEnabled, final String flushInterval) { clusterName = "es-configsync-" + System.currentTimeMillis(); // create runner instance runner = new ElasticsearchClusterRunner(); // create ES nodes runner.onBuild(new ElasticsearchClusterRunner.Builder() { @Override public void build(final int number, final Builder settingsBuilder) { settingsBuilder.put("http.cors.enabled", true); settingsBuilder.put("http.cors.allow-origin", "*"); settingsBuilder.putList("discovery.zen.ping.unicast.hosts", "localhost:9301-9310"); settingsBuilder.put("configsync.flush_interval", flushInterval); if (fileUpdaterEnabled != null) { settingsBuilder.put("configsync.file_updater.enabled", fileUpdaterEnabled.booleanValue()); } } }).build(newConfigs().clusterName(clusterName).numOfNode(numOfNode) .pluginTypes("org.codelibs.elasticsearch.configsync.ConfigSyncPlugin")); // wait for yellow status runner.ensureYellow(); configFiles = null; for (int i = 0; i < 10; i++) { if (runner.indexExists(".configsync")) { break; } try { Thread.sleep(3000L); } catch (Exception e) { // nothing } } }