org.elasticsearch.node.Node.client()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(12.6k)|赞(0)|评价(0)|浏览(99)

本文整理了Java中org.elasticsearch.node.Node.client()方法的一些代码示例，展示了Node.client()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Node.client()方法的具体详情如下：
包路径：org.elasticsearch.node.Node
类名称：Node
方法名：client

Node.client介绍

[英]A client that can be used to execute actions (operations) against the cluster.
[中]可用于对集群执行操作（操作）的客户端。

代码示例

代码示例来源：origin: stackoverflow.com

Node node = nodeBuilder().clusterName("yourcluster").client(true).node();
Client client = node.client();

代码示例来源：origin: SonarSource/sonarqube

public EsClient client() {
 return new EsClient(SHARED_NODE.client());
}

代码示例来源：origin: apache/flume

private void openLocalDiscoveryClient() {
 logger.info("Using ElasticSearch AutoDiscovery mode");
 Node node = NodeBuilder.nodeBuilder().client(true).local(true).node();
 if (client != null) {
  client.close();
 }
 client = node.client();
}

代码示例来源：origin: SonarSource/sonarqube

private static void deleteIndexIfExists(String name) {
 try {
  DeleteIndexResponse response = SHARED_NODE.client().admin().indices().prepareDelete(name).get();
  checkState(response.isAcknowledged(), "Fail to drop the index " + name);
 } catch (IndexNotFoundException e) {
  // ignore
 }
}

代码示例来源：origin: stagemonitor/stagemonitor

protected static void refresh() {
    node.client().admin().indices().prepareRefresh().get();
  }
}

代码示例来源：origin: loklak/loklak_server

/**
 * create a elasticsearch node client (embedded elasticsearch)
 * @param settings
 */
public ElasticsearchClient(final Settings.Builder settings) {
  // create a node
  this.elasticsearchNode = NodeBuilder.nodeBuilder().local(false).settings(settings).node();
  // create a client
  this.elasticsearchClient = elasticsearchNode.client();
}

代码示例来源：origin: stagemonitor/stagemonitor

protected void deleteAll() {
  node.client().admin().indices().prepareDelete("_all").get();
}

代码示例来源：origin: SonarSource/sonarqube

private void setIndexSettings(String index, Map<String, Object> settings) {
 UpdateSettingsResponse response = SHARED_NODE.client().admin().indices()
  .prepareUpdateSettings(index)
  .setSettings(settings)
  .get();
 checkState(response.isAcknowledged());
}

代码示例来源：origin: SonarSource/sonarqube

@Override
protected void after() {
 if (isCustom) {
  // delete non-core indices
  String[] existingIndices = SHARED_NODE.client().admin().indices().prepareGetIndex().get().getIndices();
  Stream.of(existingIndices)
   .filter(i -> !CORE_INDICES_NAMES.contains(i))
   .forEach(EsTester::deleteIndexIfExists);
 }
 BulkIndexer.delete(client(), new IndexType("_all", ""), client().prepareSearch("_all").setQuery(matchAllQuery()));
}

代码示例来源：origin: stagemonitor/stagemonitor

private static void startElasticsearch() throws Exception {
  try {
    FileUtils.deleteDirectory(new File("build/elasticsearch"));
  } catch (IOException e) {
    // ignore
  }
  final Settings settings = Settings.builder()
      .put("path.home", "build/elasticsearch")
      .put("node.name", "junit-es-node")
      .put("path.logs", "build/elasticsearch/logs")
      .put("path.data", "build/elasticsearch/data")
      .put("transport.type", "local")
      .put("http.type", "netty4")
      .build();
  node = new TestNode(settings, Collections.singletonList(Netty4Plugin.class));
  node.start();
  node.client().admin().cluster().prepareHealth().setWaitForGreenStatus().get();
}

代码示例来源：origin: apache/flink

.node();
Client client = node.client();

代码示例来源：origin: SonarSource/sonarqube

CreateIndexResponse indexResponse = SHARED_NODE.client().admin().indices()
 .prepareCreate(index.getName())
 .setSettings(settings)
 throw new IllegalStateException("Failed to create index " + index.getName());
SHARED_NODE.client().admin().cluster().prepareHealth(index.getName()).setWaitForStatus(ClusterHealthStatus.YELLOW).get();
 PutMappingResponse mappingResponse = SHARED_NODE.client().admin().indices().preparePutMapping(index.getName())
  .setType(entry.getKey())
  .setSource(entry.getValue().getAttributes())
SHARED_NODE.client().admin().cluster().prepareHealth(index.getName()).setWaitForStatus(ClusterHealthStatus.YELLOW).get();
result.add(index);

代码示例来源：origin: SonarSource/sonarqube

/**
 * Get all the indexed documents (no paginated results). Results are not sorted.
 */
public List<SearchHit> getDocuments(IndexType indexType) {
 SearchRequestBuilder req = SHARED_NODE.client().prepareSearch(indexType.getIndex()).setTypes(indexType.getType()).setQuery(matchAllQuery());
 EsUtils.optimizeScrollRequest(req);
 req.setScroll(new TimeValue(60000))
  .setSize(100);
 SearchResponse response = req.get();
 List<SearchHit> result = newArrayList();
 while (true) {
  Iterables.addAll(result, response.getHits());
  response = SHARED_NODE.client().prepareSearchScroll(response.getScrollId()).setScroll(new TimeValue(600000)).execute().actionGet();
  // Break condition: No hits are returned
  if (response.getHits().getHits().length == 0) {
   break;
  }
 }
 return result;
}

代码示例来源：origin: thinkaurelius/titan

@Override
  public Connection connect(Configuration config) throws IOException {
    log.debug("Configuring Node Client");
    ImmutableSettings.Builder settingsBuilder = settingsBuilder(config);
    if (config.has(ElasticSearchIndex.TTL_INTERVAL)) {
      String k = "indices.ttl.interval";
      settingsBuilder.put(k, config.get(ElasticSearchIndex.TTL_INTERVAL));
      log.debug("Set {}: {}", k, config.get(ElasticSearchIndex.TTL_INTERVAL));
    }
    makeLocalDirsIfNecessary(settingsBuilder, config);
    NodeBuilder nodeBuilder = NodeBuilder.nodeBuilder().settings(settingsBuilder.build());
    // Apply explicit Titan properties file overrides (otherwise conf-file or ES defaults apply)
    if (config.has(ElasticSearchIndex.CLIENT_ONLY)) {
      boolean clientOnly = config.get(ElasticSearchIndex.CLIENT_ONLY);
      nodeBuilder.client(clientOnly).data(!clientOnly);
    }
    if (config.has(ElasticSearchIndex.LOCAL_MODE))
      nodeBuilder.local(config.get(ElasticSearchIndex.LOCAL_MODE));
    if (config.has(ElasticSearchIndex.LOAD_DEFAULT_NODE_SETTINGS))
      nodeBuilder.loadConfigSettings(config.get(ElasticSearchIndex.LOAD_DEFAULT_NODE_SETTINGS));
    Node node = nodeBuilder.node();
    Client client = node.client();
    return new Connection(node, client);
  }
};

代码示例来源：origin: SonarSource/sonarqube

public void putDocuments(IndexType indexType, Map<String, Object>... docs) {
 try {
  BulkRequestBuilder bulk = SHARED_NODE.client().prepareBulk()
   .setRefreshPolicy(REFRESH_IMMEDIATE);
  for (Map<String, Object> doc : docs) {
   bulk.add(new IndexRequest(indexType.getIndex(), indexType.getType())
    .source(doc));
  }
  BulkResponse bulkResponse = bulk.get();
  if (bulkResponse.hasFailures()) {
   throw new IllegalStateException(bulkResponse.buildFailureMessage());
  }
 } catch (Exception e) {
  throw Throwables.propagate(e);
 }
}

代码示例来源：origin: floragunncom/search-guard

@SuppressWarnings("resource")
@Test
public void testNodeClientDisallowedWithNonServerCertificate2() throws Exception {
  setup();
  Assert.assertEquals(clusterInfo.numNodes, clusterHelper.nodeClient().admin().cluster().health(new ClusterHealthRequest().waitForGreenStatus()).actionGet().getNumberOfNodes());
  Assert.assertEquals(ClusterHealthStatus.GREEN, clusterHelper.nodeClient().admin().cluster().health(new ClusterHealthRequest().waitForGreenStatus()).actionGet().getStatus());
   final Settings tcSettings = Settings.builder()
      .put(minimumSearchGuardSettings(Settings.EMPTY).get(0))
      .put("cluster.name", clusterInfo.clustername)
      .put("node.data", false)
      .put("node.master", false)
      .put("node.ingest", false)
      .put("path.home", ".")
      .put("discovery.initial_state_timeout","8s")
      .put("searchguard.ssl.transport.keystore_filepath", FileHelper.getAbsoluteFilePathFromClassPath("spock-keystore.jks"))
      .put(SSLConfigConstants.SEARCHGUARD_SSL_TRANSPORT_KEYSTORE_ALIAS,"spock")
      .build();

  log.debug("Start node client");
  
  try (Node node = new PluginAwareNode(false, tcSettings, Netty4Plugin.class, SearchGuardPlugin.class).start()) {
    Thread.sleep(50);
    Assert.assertEquals(1, node.client().admin().cluster().nodesInfo(new NodesInfoRequest()).actionGet().getNodes().size());    
  }
}

代码示例来源：origin: floragunncom/search-guard

@SuppressWarnings("resource")
@Test
public void testNodeClientDisallowedWithNonServerCertificate() throws Exception {
  setup();
  Assert.assertEquals(clusterInfo.numNodes, clusterHelper.nodeClient().admin().cluster().health(new ClusterHealthRequest().waitForGreenStatus()).actionGet().getNumberOfNodes());
  Assert.assertEquals(ClusterHealthStatus.GREEN, clusterHelper.nodeClient().admin().cluster().health(new ClusterHealthRequest().waitForGreenStatus()).actionGet().getStatus());

  
  final Settings tcSettings = Settings.builder()
      .put(minimumSearchGuardSettings(Settings.EMPTY).get(0))
      .put("cluster.name", clusterInfo.clustername)
      .put("node.data", false)
      .put("node.master", false)
      .put("node.ingest", false)
      .put("path.home", ".")
      .put("discovery.initial_state_timeout","8s")
      .put("searchguard.ssl.transport.keystore_filepath", FileHelper.getAbsoluteFilePathFromClassPath("kirk-keystore.jks"))
      .put(SSLConfigConstants.SEARCHGUARD_SSL_TRANSPORT_KEYSTORE_ALIAS,"kirk")
      .build();

  log.debug("Start node client");
  try (Node node = new PluginAwareNode(false, tcSettings, Netty4Plugin.class, SearchGuardPlugin.class).start()) {
    Thread.sleep(50);
    Assert.assertEquals(1, node.client().admin().cluster().nodesInfo(new NodesInfoRequest()).actionGet().getNodes().size());    
  } catch (Exception e) {
    Assert.fail(e.toString());
  }
   }

代码示例来源：origin: floragunncom/search-guard

@SuppressWarnings("resource")
@Test
public void testNodeClientAllowedWithServerCertificate() throws Exception {
  setup();
  Assert.assertEquals(clusterInfo.numNodes, clusterHelper.nodeClient().admin().cluster().health(new ClusterHealthRequest().waitForGreenStatus()).actionGet().getNumberOfNodes());
  Assert.assertEquals(ClusterHealthStatus.GREEN, clusterHelper.nodeClient().admin().cluster().health(new ClusterHealthRequest().waitForGreenStatus()).actionGet().getStatus());

  
  final Settings tcSettings = Settings.builder()
      .put(minimumSearchGuardSettings(Settings.EMPTY).get(0))
      .put("cluster.name", clusterInfo.clustername)
      .put("node.data", false)
      .put("node.master", false)
      .put("node.ingest", false)
      .put("path.home", ".")
      .put("discovery.initial_state_timeout","8s")
      .putList("discovery.zen.ping.unicast.hosts", clusterInfo.nodeHost+":"+clusterInfo.nodePort)
      .build();

  log.debug("Start node client");
  
  try (Node node = new PluginAwareNode(false, tcSettings, Netty4Plugin.class, SearchGuardPlugin.class).start()) {
    Thread.sleep(50);
    Assert.assertEquals(clusterInfo.numNodes+1, node.client().admin().cluster().nodesInfo(new NodesInfoRequest()).actionGet().getNodes().size());    
  }
}

代码示例来源：origin: SonarSource/sonarqube

public void putDocuments(IndexType indexType, BaseDoc... docs) {
 try {
  BulkRequestBuilder bulk = SHARED_NODE.client().prepareBulk()
   .setRefreshPolicy(REFRESH_IMMEDIATE);
  for (BaseDoc doc : docs) {
   bulk.add(new IndexRequest(indexType.getIndex(), indexType.getType(), doc.getId())
    .parent(doc.getParent())
    .routing(doc.getRouting())
    .source(doc.getFields()));
  }
  BulkResponse bulkResponse = bulk.get();
  if (bulkResponse.hasFailures()) {
   throw new IllegalStateException(bulkResponse.buildFailureMessage());
  }
 } catch (Exception e) {
  throw Throwables.propagate(e);
 }
}

代码示例来源：origin: thinkaurelius/titan

@Test
public void testIndexCreationOptions() throws InterruptedException, BackendException {
  final int shards = 77;
  ElasticsearchRunner esr = new ElasticsearchRunner(".", "indexCreationOptions.yml");
  esr.start();
  CommonsConfiguration cc = new CommonsConfiguration(new BaseConfiguration());
  cc.set("index." + INDEX_NAME + ".elasticsearch.create.ext.number_of_shards", String.valueOf(shards));
  cc.set("index." + INDEX_NAME + ".elasticsearch.ext.cluster.name", "indexCreationOptions");
  ModifiableConfiguration config =
      new ModifiableConfiguration(GraphDatabaseConfiguration.ROOT_NS,
          cc, BasicConfiguration.Restriction.NONE);
  config.set(INTERFACE, ElasticSearchSetup.NODE.toString(), INDEX_NAME);
  Configuration indexConfig = config.restrictTo(INDEX_NAME);
  IndexProvider idx = new ElasticSearchIndex(indexConfig);
  simpleWriteAndQuery(idx);
  ImmutableSettings.Builder settingsBuilder = ImmutableSettings.settingsBuilder();
  settingsBuilder.put("discovery.zen.ping.multicast.enabled", "false");
  settingsBuilder.put("discovery.zen.ping.unicast.hosts", "localhost,127.0.0.1:9300");
  settingsBuilder.put("cluster.name", "indexCreationOptions");
  NodeBuilder nodeBuilder = NodeBuilder.nodeBuilder().settings(settingsBuilder.build());
  nodeBuilder.client(true).data(false).local(false);
  Node n = nodeBuilder.build().start();
  GetSettingsResponse response = n.client().admin().indices().getSettings(new GetSettingsRequest().indices("titan")).actionGet();
  assertEquals(String.valueOf(shards), response.getSetting("titan", "index.number_of_shards"));
  idx.close();
  n.stop();
  esr.stop();
}

内容来源于网络，如有侵权，请联系作者删除！

Node

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com