org.elasticsearch.client.transport.TransportClient.prepareSearch()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(9.8k)|赞(0)|评价(0)|浏览(201)

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

TransportClient.prepareSearch介绍

暂无

代码示例

代码示例来源：origin: alibaba/canal

@Override
public Map<String, Object> count(String task) {
  ESSyncConfig config = esSyncConfig.get(task);
  ESMapping mapping = config.getEsMapping();
  SearchResponse response = transportClient.prepareSearch(mapping.get_index())
    .setTypes(mapping.get_type())
    .setSize(0)
    .get();
  long rowCount = response.getHits().getTotalHits();
  Map<String, Object> res = new LinkedHashMap<>();
  res.put("esIndex", mapping.get_index());
  res.put("count", rowCount);
  return res;
}

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

try {
  tc.threadPool().getThreadContext().putHeader("sg_impersonate_as", "nagilum");
  SearchResponse searchRes = tc.prepareSearch("starfleet").setTypes("ships").setScroll(TimeValue.timeValueMinutes(5)).get();
  scrollId = searchRes.getScrollId();
} finally {
try {
  tc.threadPool().getThreadContext().putHeader("sg_impersonate_as", "nagilum");
  searchRes = tc.prepareSearch("starfleet").setTypes("ships").setScroll(TimeValue.timeValueMinutes(5)).get();
} finally {
  ctx.close();
try {
  tc.threadPool().getThreadContext().putHeader("sg_impersonate_as", "nagilum");
  searchRes = tc.prepareSearch("starfleet").setTypes("ships").setScroll(TimeValue.timeValueMinutes(5)).get();
  SearchResponse scrollRes = tc.prepareSearchScroll(searchRes.getScrollId()).get();
  Assert.assertEquals(0, scrollRes.getFailedShards());

代码示例来源：origin: prestodb/presto

public SearchRequestBuilder buildScrollSearchRequest()
{
  String indices = index != null && !index.isEmpty() ? index : "_all";
  List<String> fields = columns.stream()
      .map(ElasticsearchColumnHandle::getColumnName)
      .collect(toList());
  SearchRequestBuilder searchRequestBuilder = client.prepareSearch(indices)
      .setTypes(type)
      .setSearchType(QUERY_THEN_FETCH)
      .setScroll(new TimeValue(scrollTimeout.toMillis()))
      .setFetchSource(fields.toArray(new String[0]), null)
      .setQuery(buildSearchQuery())
      .setPreference("_shards:" + shard)
      .setSize(scrollSize);
  LOG.debug("Elasticsearch Request: %s", searchRequestBuilder);
  return searchRequestBuilder;
}

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

try {
  tc.threadPool().getThreadContext().putHeader("sg_impersonate_as", "nagilum");
  SearchResponse searchRes = tc.prepareSearch("starfleet").setTypes("ships").setScroll(TimeValue.timeValueMinutes(5)).get();
  scrollId = searchRes.getScrollId();
} finally {
try {
  tc.threadPool().getThreadContext().putHeader("sg_impersonate_as", "nagilum");
  searchRes = tc.prepareSearch("starfleet").setTypes("ships").setScroll(TimeValue.timeValueMinutes(5)).get();
} finally {
  ctx.close();
try {
  tc.threadPool().getThreadContext().putHeader("sg_impersonate_as", "nagilum");
  searchRes = tc.prepareSearch("starfleet").setTypes("ships").setScroll(TimeValue.timeValueMinutes(5)).get();
  SearchResponse scrollRes = tc.prepareSearchScroll(searchRes.getScrollId()).get();
  Assert.assertEquals(0, scrollRes.getFailedShards());

代码示例来源：origin: brianfrankcooper/YCSB

refreshIfNeeded();
final RangeQueryBuilder query = new RangeQueryBuilder(KEY).gte(startkey);
final SearchResponse response = client.prepareSearch(indexKey).setQuery(query).setSize(recordcount).get();

代码示例来源：origin: brianfrankcooper/YCSB

private SearchResponse search(final String table, final String key) {
 refreshIfNeeded();
 return client.prepareSearch(indexKey).setTypes(table).setQuery(new TermQueryBuilder(KEY, key)).get();
}

代码示例来源：origin: alibaba/canal

paramsTmp.forEach((fieldName, value) -> queryBuilder.must(QueryBuilders.termsQuery(fieldName, value)));
SearchResponse response = transportClient.prepareSearch(mapping.get_index())
  .setTypes(mapping.get_type())
  .setSize(0)

代码示例来源：origin: alibaba/canal

if (mapping.getParent() == null) {
  SearchResponse response = transportClient.prepareSearch(mapping.get_index())
    .setTypes(mapping.get_type())
    .setQuery(QueryBuilders.termQuery(mapping.getPk(), idVal))

代码示例来源：origin: alibaba/canal

public void append4Update(BulkRequestBuilder bulkRequestBuilder, ESMapping mapping, Object pkVal,
             Map<String, Object> esFieldData) {
  if (mapping.get_id() != null) {
    bulkRequestBuilder
      .add(transportClient.prepareUpdate(mapping.get_index(), mapping.get_type(), pkVal.toString())
        .setDoc(esFieldData));
  } else {
    SearchResponse response = transportClient.prepareSearch(mapping.get_index())
      .setTypes(mapping.get_type())
      .setQuery(QueryBuilders.termQuery(mapping.getPk(), pkVal))
      .setSize(MAX_BATCH_SIZE)
      .get();
    for (SearchHit hit : response.getHits()) {
      bulkRequestBuilder
        .add(transportClient.prepareUpdate(mapping.get_index(), mapping.get_type(), hit.getId())
          .setDoc(esFieldData));
    }
  }
}

代码示例来源：origin: alibaba/canal

/**
 * 通过主键删除数据
 *
 * @param mapping
 * @param pkVal
 * @return
 */
public boolean delete(ESMapping mapping, Object pkVal) {
  BulkRequestBuilder bulkRequestBuilder = transportClient.prepareBulk();
  if (mapping.get_id() != null) {
    bulkRequestBuilder
      .add(transportClient.prepareDelete(mapping.get_index(), mapping.get_type(), pkVal.toString()));
  } else {
    SearchResponse response = transportClient.prepareSearch(mapping.get_index())
      .setTypes(mapping.get_type())
      .setQuery(QueryBuilders.termQuery(mapping.getPk(), pkVal))
      .setSize(MAX_BATCH_SIZE)
      .get();
    for (SearchHit hit : response.getHits()) {
      bulkRequestBuilder
        .add(transportClient.prepareDelete(mapping.get_index(), mapping.get_type(), hit.getId()));
    }
  }
  return commitBulkRequest(bulkRequestBuilder);
}

代码示例来源：origin: alibaba/canal

/**
 * 插入数据
 * 
 * @param mapping
 * @param pkVal
 * @param esFieldData
 * @return
 */
public boolean insert(ESMapping mapping, Object pkVal, Map<String, Object> esFieldData) {
  BulkRequestBuilder bulkRequestBuilder = transportClient.prepareBulk();
  if (mapping.get_id() != null) {
    bulkRequestBuilder
      .add(transportClient.prepareIndex(mapping.get_index(), mapping.get_type(), pkVal.toString())
        .setSource(esFieldData));
  } else {
    SearchResponse response = transportClient.prepareSearch(mapping.get_index())
      .setTypes(mapping.get_type())
      .setQuery(QueryBuilders.termQuery(mapping.getPk(), pkVal))
      .setSize(MAX_BATCH_SIZE)
      .get();
    for (SearchHit hit : response.getHits()) {
      bulkRequestBuilder
        .add(transportClient.prepareDelete(mapping.get_index(), mapping.get_type(), hit.getId()));
    }
    bulkRequestBuilder
      .add(transportClient.prepareIndex(mapping.get_index(), mapping.get_type()).setSource(esFieldData));
  }
  return commitBulkRequest(bulkRequestBuilder);
}

代码示例来源：origin: Impetus/Kundera

@Override
public <E> List<E> getColumnsById(String schemaName, String tableName, String pKeyColumnName, String columnName,
    Object pKeyColumnValue, Class columnJavaType)
{
  // fetch list ADDRESS_ID for given PERSON_ID
  QueryBuilder filterBuilder = new TermQueryBuilder(pKeyColumnName, pKeyColumnValue);
  SearchResponse response = txClient.prepareSearch(schemaName.toLowerCase()).setTypes(tableName)
      .setPostFilter(filterBuilder).addField(columnName).execute().actionGet();
  SearchHits hits = response.getHits();
  List columns = new ArrayList();
  for (SearchHit hit : hits.getHits())
  {
    Map<String, SearchHitField> fields = hit.getFields();
    columns.add(fields.get(columnName).getValue());
  }
  return columns;
}

代码示例来源：origin: Impetus/Kundera

@Override
public Object[] findIdsByColumn(String schemaName, String tableName, String pKeyName, String columnName,
    Object columnValue, Class entityClazz)
{
  TermQueryBuilder filter = QueryBuilders.termQuery(columnName, columnValue);
  SearchResponse response = txClient.prepareSearch(schemaName.toLowerCase()).setTypes(tableName)
      .addField(pKeyName).setPostFilter(filter).execute().actionGet();
  SearchHits hits = response.getHits();
  Long length = hits.getTotalHits();
  int absoluteLength = length.intValue();
  Object[] ids = new Object[absoluteLength];
  int counter = 0;
  for (SearchHit hit : hits.getHits())
  {
    Map<String, SearchHitField> fields = hit.getFields();
    ids[counter++] = fields.get(pKeyName).getValue();
  }
  return ids;
}

代码示例来源：origin: Impetus/Kundera

.prepareSearch(metadata.getSchema()

代码示例来源：origin: Impetus/Kundera

SearchRequestBuilder builder = txClient.prepareSearch(entityMetadata.getSchema().toLowerCase())
    .setTypes(entityMetadata.getTableName());

代码示例来源：origin: petterobam/database-oop

/**
 * @param index 索引
 * @param type 类型
 * @return d
 */
public SearchRequestBuilder searchRequest(String index, String type) {
  return client.prepareSearch(index).setTypes(type);
}

代码示例来源：origin: io.leopard/leopard-elasticsearch

@Override
public SearchHits search(QueryBuilder query, int start, int size) {
  SearchResponse response = client.prepareSearch().setQuery(query).setFrom(start).setSize(size).execute().actionGet();
  return response.getHits();
}

代码示例来源：origin: io.leopard/leopard-elasticsearch

@Override
public SearchHits search(QueryBuilder query, String orderField, int start, int size) {
  SearchResponse response = client.prepareSearch().setQuery(query).addSort(orderField, SortOrder.DESC).setFrom(start).setSize(size).execute().actionGet();
  return response.getHits();
}

代码示例来源：origin: lumifyio/securegraph

protected SearchRequestBuilder getSearchRequestBuilder(List<FilterBuilder> filters, QueryBuilder queryBuilder) {
  AndFilterBuilder filterBuilder = getFilterBuilder(filters);
  return getClient()
      .prepareSearch(getIndicesToQuery())
      .setTypes(ElasticSearchSearchIndexBase.ELEMENT_TYPE)
      .setQuery(QueryBuilders.filteredQuery(queryBuilder, filterBuilder))
      .setFrom((int) getParameters().getSkip())
      .setSize((int) getParameters().getLimit());
}

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

protected SearchRequestBuilder getSearchRequestBuilder(List<FilterBuilder> filters, QueryBuilder queryBuilder) {
  AndFilterBuilder filterBuilder = getFilterBuilder(filters);
  return getClient()
      .prepareSearch(getIndicesToQuery())
      .setTypes(ElasticSearchSearchIndexBase.ELEMENT_TYPE)
      .setQuery(QueryBuilders.filteredQuery(queryBuilder, filterBuilder))
      .setFrom((int) getParameters().getSkip())
      .setSize((int) getParameters().getLimit());
}

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

TransportClient

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    TransportClient类方法

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