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

NodeClient.index介绍

暂无

代码示例

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

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  IndexRequest indexRequest = new IndexRequest(request.param("index"), request.param("type"), request.param("id"));
  indexRequest.routing(request.param("routing"));
  indexRequest.parent(request.param("parent"));
  indexRequest.setPipeline(request.param("pipeline"));
  indexRequest.source(request.requiredContent(), request.getXContentType());
  indexRequest.timeout(request.paramAsTime("timeout", IndexRequest.DEFAULT_TIMEOUT));
  indexRequest.setRefreshPolicy(request.param("refresh"));
  indexRequest.version(RestActions.parseVersion(request));
  indexRequest.versionType(VersionType.fromString(request.param("version_type"), indexRequest.versionType()));
  indexRequest.setIfSeqNo(request.paramAsLong("if_seq_no", indexRequest.ifSeqNo()));
  indexRequest.setIfPrimaryTerm(request.paramAsLong("if_primary_term", indexRequest.ifPrimaryTerm()));
  String sOpType = request.param("op_type");
  String waitForActiveShards = request.param("wait_for_active_shards");
  if (waitForActiveShards != null) {
    indexRequest.waitForActiveShards(ActiveShardCount.parseString(waitForActiveShards));
  }
  if (sOpType != null) {
    indexRequest.opType(sOpType);
  }
  return channel ->
      client.index(indexRequest, new RestStatusToXContentListener<>(channel, r -> r.getLocation(indexRequest.routing())));
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  IndexRequest indexRequest = new IndexRequest(request.param("index"), request.param("type"), request.param("id"));
  indexRequest.routing(request.param("routing"));
  indexRequest.parent(request.param("parent"));
  indexRequest.setPipeline(request.param("pipeline"));
  indexRequest.source(request.requiredContent(), request.getXContentType());
  indexRequest.timeout(request.paramAsTime("timeout", IndexRequest.DEFAULT_TIMEOUT));
  indexRequest.setRefreshPolicy(request.param("refresh"));
  indexRequest.version(RestActions.parseVersion(request));
  indexRequest.versionType(VersionType.fromString(request.param("version_type"), indexRequest.versionType()));
  String sOpType = request.param("op_type");
  String waitForActiveShards = request.param("wait_for_active_shards");
  if (waitForActiveShards != null) {
    indexRequest.waitForActiveShards(ActiveShardCount.parseString(waitForActiveShards));
  }
  if (sOpType != null) {
    indexRequest.opType(sOpType);
  }
  return channel ->
      client.index(indexRequest, new RestStatusToXContentListener<>(channel, r -> r.getLocation(indexRequest.routing())));
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  IndexRequest indexRequest = new IndexRequest(request.param("index"), request.param("type"), request.param("id"));
  indexRequest.routing(request.param("routing"));
  indexRequest.parent(request.param("parent"));
  indexRequest.setPipeline(request.param("pipeline"));
  indexRequest.source(request.requiredContent(), request.getXContentType());
  indexRequest.timeout(request.paramAsTime("timeout", IndexRequest.DEFAULT_TIMEOUT));
  indexRequest.setRefreshPolicy(request.param("refresh"));
  indexRequest.version(RestActions.parseVersion(request));
  indexRequest.versionType(VersionType.fromString(request.param("version_type"), indexRequest.versionType()));
  String sOpType = request.param("op_type");
  String waitForActiveShards = request.param("wait_for_active_shards");
  if (waitForActiveShards != null) {
    indexRequest.waitForActiveShards(ActiveShardCount.parseString(waitForActiveShards));
  }
  if (sOpType != null) {
    indexRequest.opType(sOpType);
  }
  return channel ->
      client.index(indexRequest, new RestStatusToXContentListener<>(channel, r -> r.getLocation(indexRequest.routing())));
}

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

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  IndexRequest indexRequest = new IndexRequest(request.param("index"), request.param("type"), request.param("id"));
  indexRequest.routing(request.param("routing"));
  indexRequest.parent(request.param("parent")); // order is important, set it after routing, so it will set the routing
  if (request.hasParam("timestamp")) {
    deprecationLogger.deprecated("The [timestamp] parameter of index requests is deprecated");
  }
  indexRequest.timestamp(request.param("timestamp"));
  if (request.hasParam("ttl")) {
    deprecationLogger.deprecated("The [ttl] parameter of index requests is deprecated");
    indexRequest.ttl(request.param("ttl"));
  }
  indexRequest.setPipeline(request.param("pipeline"));
  indexRequest.source(request.requiredContent(), request.getXContentType());
  indexRequest.timeout(request.paramAsTime("timeout", IndexRequest.DEFAULT_TIMEOUT));
  indexRequest.setRefreshPolicy(request.param("refresh"));
  indexRequest.version(RestActions.parseVersion(request));
  indexRequest.versionType(VersionType.fromString(request.param("version_type"), indexRequest.versionType()));
  String sOpType = request.param("op_type");
  String waitForActiveShards = request.param("wait_for_active_shards");
  if (waitForActiveShards != null) {
    indexRequest.waitForActiveShards(ActiveShardCount.parseString(waitForActiveShards));
  }
  if (sOpType != null) {
    indexRequest.opType(sOpType);
  }
  return channel ->
      client.index(indexRequest, new RestStatusToXContentListener<>(channel, r -> r.getLocation(indexRequest.routing())));
}