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

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

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

Node.<init>介绍

[英]Constructs a node with the given settings.
[中]使用给定的设置构造一个节点。

代码示例

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

  1. private static Node createNode() {
  2.   try {
  3.    Path tempDir = Files.createTempDirectory("EsTester");
  4.    tempDir.toFile().deleteOnExit();
  5.    Settings settings = Settings.builder()
  6.     .put(Environment.PATH_HOME_SETTING.getKey(), tempDir)
  7.     .put("node.name", "EsTester")
  8.     .put(NodeEnvironment.MAX_LOCAL_STORAGE_NODES_SETTING.getKey(), Integer.MAX_VALUE)
  9.     .put("logger.level", "INFO")
  10.     .put("action.auto_create_index", false)
  11.     // Default the watermarks to absurdly low to prevent the tests
  12.     // from failing on nodes without enough disk space
  13.     .put(DiskThresholdSettings.CLUSTER_ROUTING_ALLOCATION_LOW_DISK_WATERMARK_SETTING.getKey(), "1b")
  14.     .put(DiskThresholdSettings.CLUSTER_ROUTING_ALLOCATION_HIGH_DISK_WATERMARK_SETTING.getKey(), "1b")
  15.     // always reduce this - it can make tests really slow
  16.     .put(RecoverySettings.INDICES_RECOVERY_RETRY_DELAY_STATE_SYNC_SETTING.getKey(), TimeValue.timeValueMillis(20))
  17.     .put(NetworkModule.TRANSPORT_TYPE_KEY, "local")
  18.     .put(NetworkModule.HTTP_ENABLED.getKey(), false)
  19.     .put(DiscoveryModule.DISCOVERY_TYPE_SETTING.getKey(), "single-node")
  20.     .build();
  21.    Node node = new Node(settings);
  22.    return node.start();
  23.   } catch (Exception e) {
  24.    throw new IllegalStateException("Fail to start embedded Elasticsearch", e);
  25.   }
  26.  }
  27. }

代码示例来源：origin: harbby/presto-connectors

  1. /**
  2.  * Builds the node without starting it.
  3.  */
  4. public Node build() {
  5.   return new Node(settings.build());
  6. }

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

  1. public Node newNode(Settings settings, Collection<Class<? extends Plugin>> classpathPlugins) {
  2.   Settings nodeSettings = nodeSettings(settings);
  3.   System.out.println("node settings="+nodeSettings.getAsMap());
  4.   System.out.println("node plugins="+classpathPlugins);
  5.   this.node = new Node(nodeSettings, classpathPlugins);
  6.   return this.node;
  7. }

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

  1. /** Constructs an internal node used as a client into a cluster fronted by this tribe node. */
  2. protected Node newTribeClientNode(Settings settings, Collection<Class<? extends Plugin>> classpathPlugins) {
  3.   return new Node(new Environment(settings), classpathPlugins);
  4. }

代码示例来源：origin: searchhub/preDict

  1. private Node newNode() {
  2.   File tempDir = Files.createTempDir();
  3.   Settings settings = Settings.builder()
  4.       .put(Environment.PATH_HOME_SETTING.getKey(), tempDir)
  5.       .put("node.name", "node_s_0")
  6.       .put(NetworkModule.HTTP_ENABLED.getKey(), false)
  7.       .put("transport.type", "local")
  8.       .put(Node.NODE_DATA_SETTING.getKey(), true)
  9.       .build();
  10.   Node build = new Node(settings);
  11.   try {
  12.     build.start();
  13.   } catch (NodeValidationException e) {
  14.     throw new RuntimeException(e);
  15.   }
  16.   return build;
  17. }

代码示例来源：origin: com.jeromeloisel/db-integration-test

  1. @Bean(destroyMethod="close")
  2. Node newNode() throws NodeValidationException {
  3.  final Path tempDir = createTempDir().toPath();
  4.  final Settings settings = Settings.builder()
  5.   .put(ClusterName.CLUSTER_NAME_SETTING.getKey(), new ClusterName("single-node-cluster" + System.nanoTime()))
  6.   .put(Environment.PATH_HOME_SETTING.getKey(), tempDir)
  7.   .put(Environment.PATH_REPO_SETTING.getKey(), tempDir.resolve("repo"))
  8.   .put(Environment.PATH_SHARED_DATA_SETTING.getKey(), createTempDir().getParent())
  9.   .put("node.name", "single-node")
  10.   .put("script.inline", "true")
  11.   .put("script.stored", "true")
  12.   .put(ScriptService.SCRIPT_MAX_COMPILATIONS_PER_MINUTE.getKey(), 1000)
  13.   .put(EsExecutors.PROCESSORS_SETTING.getKey(), 1)
  14.   .put(NetworkModule.HTTP_ENABLED.getKey(), false)
  15.   .put("discovery.type", "zen")
  16.   .put("transport.type", "local")
  17.   .put(Node.NODE_DATA_SETTING.getKey(), true)
  18.   .put(NODE_ID_SEED_SETTING.getKey(), System.nanoTime())
  19.   .build();
  20.  return new Node(settings).start(); // NOSONAR
  21. }

代码示例来源：origin: jloisel/elastic-crud

  1. @Bean(destroyMethod="close")
  2. Node newNode() throws NodeValidationException {
  3.  final Path tempDir = createTempDir().toPath();
  4.  final Settings settings = Settings.builder()
  5.   .put(ClusterName.CLUSTER_NAME_SETTING.getKey(), new ClusterName("single-node-cluster" + System.nanoTime()))
  6.   .put(Environment.PATH_HOME_SETTING.getKey(), tempDir)
  7.   .put(Environment.PATH_REPO_SETTING.getKey(), tempDir.resolve("repo"))
  8.   .put(Environment.PATH_SHARED_DATA_SETTING.getKey(), createTempDir().getParent())
  9.   .put("node.name", "single-node")
  10.   .put("script.inline", "true")
  11.   .put("script.stored", "true")
  12.   .put(ScriptService.SCRIPT_MAX_COMPILATIONS_PER_MINUTE.getKey(), 1000)
  13.   .put(EsExecutors.PROCESSORS_SETTING.getKey(), 1)
  14.   .put(NetworkModule.HTTP_ENABLED.getKey(), false)
  15.   .put("discovery.type", "zen")
  16.   .put("transport.type", "local")
  17.   .put(Node.NODE_DATA_SETTING.getKey(), true)
  18.   .put(NODE_ID_SEED_SETTING.getKey(), System.nanoTime())
  19.   .build();
  20.  return new Node(settings).start(); // NOSONAR
  21. }

代码示例来源：origin: apache/attic-polygene-java

  1. @Override
  2. protected void activateElasticSearch()
  3.   throws Exception
  4. {
  5.   configuration.refresh();
  6.   ElasticSearchIndexingConfiguration config = configuration.get();
  7.   String clusterName = config.clusterName().get() == null ? DEFAULT_CLUSTER_NAME : config.clusterName().get();
  8.   index = config.index().get() == null ? DEFAULT_INDEX_NAME : config.index().get();
  9.   indexNonAggregatedAssociations = config.indexNonAggregatedAssociations().get();
  10.   Identity identity = hasIdentity.identity().get();
  11.   File homeDir = new File( new File( fileConfig.temporaryDirectory(), identity.toString() ), "home" );
  12.   File logsDir = new File( fileConfig.logDirectory(), identity.toString() );
  13.   File dataDir = new File( fileConfig.dataDirectory(), identity.toString() );
  14.   File confDir = new File( fileConfig.configurationDirectory(), identity.toString() );
  15.   Stream.of( homeDir, logsDir, dataDir, confDir ).forEach( File::mkdirs );
  16.   Settings settings = Settings.builder()
  17.                 .put( "cluster.name", clusterName )
  18.                 .put( "path.home", homeDir.getAbsolutePath() )
  19.                 .put( "path.logs", logsDir.getAbsolutePath() )
  20.                 .put( "path.data", dataDir.getAbsolutePath() )
  21.                 .put( "path.conf", confDir.getAbsolutePath() )
  22.                 .put( "transport.type", "local" )
  23.                 .put( "http.enabled", false )
  24.                 .build();
  25.   node = new Node( settings );
  26.   node.start();
  27.   client = node.client();
  28. }

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

  1. this.node = new Node(getSettings(), pluginList);

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

Node

相关文章

    查看更多

    热门标签

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

    最新文章

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