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

x33g5p2x  于2022-01-28 转载在 其他  
字(10.1k)|赞(0)|评价(0)|浏览(129)

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

Requests.indexRequest介绍

[英]Create an index request against a specific index. Note the IndexRequest#type(String) must be set as well and optionally the IndexRequest#id(String).
[中]针对特定索引创建索引请求。注意，还必须设置IndexRequest#类型（字符串）和IndexRequest#id（字符串）。

代码示例

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

private static IndexRequest createIndexRequest(String element, ParameterTool parameterTool) {
  Map<String, Object> json = new HashMap<>();
  json.put("data", element);
  return Requests.indexRequest()
    .index(parameterTool.getRequired("index"))
    .type(parameterTool.getRequired("type"))
    .id(element)
    .source(json);
}

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

private static IndexRequest createIndexRequest(String element, ParameterTool parameterTool) {
  Map<String, Object> json = new HashMap<>();
  json.put("data", element);
  return Requests.indexRequest()
    .index(parameterTool.getRequired("index"))
    .type(parameterTool.getRequired("type"))
    .id(element)
    .source(json);
}

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

private static IndexRequest createIndexRequest(String element, ParameterTool parameterTool) {
  Map<String, Object> json = new HashMap<>();
  json.put("data", element);
  return Requests.indexRequest()
    .index(parameterTool.getRequired("index"))
    .type(parameterTool.getRequired("type"))
    .id(element)
    .source(json);
}

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

private static IndexRequest createIndexRequest(String element, ParameterTool parameterTool) {
    Map<String, Object> json = new HashMap<>();
    json.put("data", element);

    return Requests.indexRequest()
      .index(parameterTool.getRequired("index"))
      .type(parameterTool.getRequired("type"))
      .id(element)
      .source(json);
  }
}

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

private static IndexRequest createIndexRequest(String element, ParameterTool parameterTool) {
  Map<String, Object> json = new HashMap<>();
  json.put("data", element);
  return Requests.indexRequest()
    .index(parameterTool.getRequired("index"))
    .type(parameterTool.getRequired("type"))
    .id(element)
    .source(json);
}

代码示例来源：origin: richardwilly98/elasticsearch-river-mongodb

public void addBulkRequest(String id, Map<?, ?> source, String routing, String parent) {
  bulkProcessor.add(indexRequest(index).type(type).id(id).source(source).routing(routing).parent(parent));
  insertedDocuments.incrementAndGet();
}

代码示例来源：origin: richardwilly98/elasticsearch-river-mongodb

public void addBulkRequest(String id, XContentBuilder source, String routing, String parent) {
  bulkProcessor.add(indexRequest(index).type(type).id(id).source(source).routing(routing).parent(parent));
  insertedDocuments.incrementAndGet();
}

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

@Override
  public void process(String element, RuntimeContext ctx, RequestIndexer indexer) {
    Map<java.lang.String, Object> json = new HashMap<>();
    json.put("data", element);
    indexer.add(
      Requests.indexRequest()
        .index("index")
        .type("type")
        .id("id")
        .source(json)
    );
  }
}

代码示例来源：origin: richardwilly98/elasticsearch-river-mongodb

/**
 * Adds an index request operation to a bulk request, updating the last
 * timestamp for a given namespace (ie: host:dbName.collectionName)
 * 
 * @param bulk
 */
void setLastTimestamp(final Timestamp<?> time, final BulkProcessor bulkProcessor) {
  try {
    if (logger.isTraceEnabled()) {
      logger.trace("setLastTimestamp [{}] [{}]", definition.getMongoOplogNamespace(), time);
    }
    bulkProcessor.add(indexRequest(definition.getRiverIndexName()).type(definition.getRiverName())
        .id(definition.getMongoOplogNamespace()).source(source(time)));
  } catch (IOException e) {
    logger.error("error updating last timestamp for namespace {}", definition.getMongoOplogNamespace());
  }
}

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

final IndexRequest indexRequest = Requests.indexRequest(request.index())
    .type(request.type()).id(request.id()).routing(routing).parent(parent)
    .source(updatedSourceAsMap, updateSourceContentType).version(updateVersion).versionType(request.versionType())

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

protected IndexRequest getRequest(OutgoingMessageEnvelope envelope) {
 String[] parts = envelope.getSystemStream().getStream().split("/");
 if (parts.length != 2) {
  throw new SamzaException("Elasticsearch stream name must match pattern {index}/{type}");
 }
 String index = parts[0];
 String type = parts[1];
 return Requests.indexRequest(index).type(type);
}

代码示例来源：origin: srecon/elasticsearch-cassandra-river

public void run() {
  LOGGER.info("Starting thread with Data {}, batch size {} for {}", this.keys.size(), this.batchSize, this.indexName);
  BulkRequestBuilder bulk = getClient().prepareBulk();
  for(String key : this.keys.keySet()){
    try{
      bulk.add(Requests.indexRequest(this.indexName).type(this.typeName)
          .id(key).source(this.keys.get(key)));
    } catch(Exception e){
      LOGGER.error("{} run had an Exception {}", this.indexName, e);
    }
  }
  saveToEs(bulk);
}

代码示例来源：origin: jprante/elasticsearch-transport-websocket

/**
 * Checkpointing a topic or a subscriber. The current timestamp is written
 * to the checkpoint index type. Note that bulk index requests are used by
 * checkpointing and flushCheckpoint() needs to be called after all is done.
 *
 * @param id topic or subscriber
 * @throws IOException if this method fails
 */
public void checkpoint(String id) throws IOException {
  indexBulk(Requests.indexRequest(pubSubIndexName).type(TYPE).id(id)
      .source(jsonBuilder().startObject().field("timestamp", System.currentTimeMillis()).endObject()), null);
}

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

/**
 * Prepare the request for merging the existing document with a new one, can optionally detect a noop change. Returns a {@code Result}
 * containing a new {@code IndexRequest} to be executed on the primary and replicas.
 */
Result prepareUpdateIndexRequest(ShardId shardId, UpdateRequest request, GetResult getResult, boolean detectNoop) {
  final long updateVersion = calculateUpdateVersion(request, getResult);
  final IndexRequest currentRequest = request.doc();
  final String routing = calculateRouting(getResult, currentRequest);
  final String parent = calculateParent(getResult, currentRequest);
  final Tuple<XContentType, Map<String, Object>> sourceAndContent = XContentHelper.convertToMap(getResult.internalSourceRef(), true);
  final XContentType updateSourceContentType = sourceAndContent.v1();
  final Map<String, Object> updatedSourceAsMap = sourceAndContent.v2();
  final boolean noop = !XContentHelper.update(updatedSourceAsMap, currentRequest.sourceAsMap(), detectNoop);
  // We can only actually turn the update into a noop if detectNoop is true to preserve backwards compatibility and to handle cases
  // where users repopulating multi-fields or adding synonyms, etc.
  if (detectNoop && noop) {
    UpdateResponse update = new UpdateResponse(shardId, getResult.getType(), getResult.getId(),
        getResult.getVersion(), DocWriteResponse.Result.NOOP);
    update.setGetResult(extractGetResult(request, request.index(), getResult.getSeqNo(), getResult.getPrimaryTerm(),
      getResult.getVersion(), updatedSourceAsMap, updateSourceContentType, getResult.internalSourceRef()));
    return new Result(update, DocWriteResponse.Result.NOOP, updatedSourceAsMap, updateSourceContentType);
  } else {
    final IndexRequest finalIndexRequest = Requests.indexRequest(request.index())
        .type(request.type()).id(request.id()).routing(routing).parent(parent)
        .source(updatedSourceAsMap, updateSourceContentType).version(updateVersion).versionType(request.versionType())
        .waitForActiveShards(request.waitForActiveShards()).timeout(request.timeout())
        .setRefreshPolicy(request.getRefreshPolicy());
    return new Result(finalIndexRequest, DocWriteResponse.Result.UPDATED, updatedSourceAsMap, updateSourceContentType);
  }
}

代码示例来源：origin: salyh/elasticsearch-imap

protected IndexRequest createIndexRequest(final IndexableMailMessage message) throws IOException {
  final String id = (!StringUtils.isEmpty(message.getPopId()) ? message.getPopId() : message.getUid()) + "::"
      + message.getFolderUri();
  
  //if(logger.isTraceEnabled()) {
  //   logger.trace("Message: "+message.build());
  //}
  
  final IndexRequest request = Requests.indexRequest(index).type(type).id(id).source(message.build());
  return request;
}

代码示例来源：origin: spinscale/elasticsearch-river-streaming-json

private void addProductToBulkRequest(RiverProduct riverProduct) {
  if (riverProduct.action == RiverProduct.Action.DELETE) {
    //bulk.add(deleteRequest(RIVER_INDEX).type(RIVER_TYPE).id(riverProduct.id));
    logger.error("DELETING {}/{}/{}", RIVER_INDEX, RIVER_TYPE, riverProduct.id);
    client.prepareDelete(RIVER_INDEX, RIVER_TYPE, riverProduct.id).execute().actionGet();
    deletedDocuments++;
  } else {
    logger.error("INDEXING {}/{}/{}", RIVER_INDEX, RIVER_TYPE, riverProduct.id);
    bulk.add(indexRequest(RIVER_INDEX).type(RIVER_TYPE).id(riverProduct.id).source(riverProduct.product));
    insertedDocuments++;
  }
}

代码示例来源：origin: spinscale/elasticsearch-river-streaming-json

private void storeLastUpdatedTimestamp(String exportTimestamp) {
  String json = "{ \"lastUpdatedTimestamp\" : \"" + exportTimestamp + "\" }";
  IndexRequest updateTimestampRequest = indexRequest(riverIndexName).type(riverName.name()).id("lastUpdatedTimestamp").source(json);
  client.index(updateTimestampRequest).actionGet();
}

代码示例来源：origin: javanna/elasticshell

private void indexLine(BulkProcessor bulkProcessor, String index, String type, String line) {
  try {
    Document document = Document.fromDump(line);
    bulkProcessor.add(Requests.indexRequest(index == null ? document.getIndex() : index)
        .type(type == null ? document.getType() : type)
        .id(document.getId()).source(document.getDocument()));
  } catch(Exception e) {
    logger.error("Error while indexing document {}", line, e);
  }
}

代码示例来源：origin: ezbz/projectx

@Override
 public ActionFuture<IndexResponse> execute(final Client client) {
  final IndexRequest request = Requests.indexRequest(nodeTemplate.getIndexName())
                     .source(content).type("log");
  return client.index(request);
 }
});

代码示例来源：origin: com.netflix.suro/suro-elasticsearch

private IndexRequest createIndexRequest(Message m) {
  IndexInfo info = indexInfo.create(m);
  if (info == null) {
    ++parsingFailedRowCount;
    return null;
  } else {
    return Requests.indexRequest(info.getIndex())
            .type(info.getType())
            .source(info.getSource())
            .id(info.getId())
            .opType(IndexRequest.OpType.CREATE);
  }
}

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

Requests

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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