org.apache.nifi.provenance.search.Query.getMaxResults()方法的使用及代码示例

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

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

Query.getMaxResults介绍

暂无

代码示例

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

  1. @Override
  2. public boolean isFinished() {
  3.   readLock.lock();
  4.   try {
  5.     return numCompletedSteps >= numSteps || canceled || matchingRecords.size() >= query.getMaxResults();
  6.   } finally {
  7.     readLock.unlock();
  8.   }
  9. }

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

  1. @Override
  2. public long getTotalHitCount() {
  3.   readLock.lock();
  4.   try {
  5.     // Because we filter the results based on the user's permissions,
  6.     // we don't want to indicate that the total hit count is 1,000+ when we
  7.     // have 0 matching records, for instance. So, if we have fewer matching
  8.     // records than the max specified by the query, it is either the case that
  9.     // we truly don't have enough records to reach the max results, or that
  10.     // the user is not authorized to see some of the results. Either way,
  11.     // we want to report the number of events that we find AND that the user
  12.     // is allowed to see, so we report matching record count, or up to max results.
  13.     if (matchingRecords.size() < query.getMaxResults()) {
  14.       return matchingRecords.size();
  15.     } else {
  16.       return query.getMaxResults();
  17.     }
  18.   } finally {
  19.     readLock.unlock();
  20.   }
  21. }

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

  1. @Override
  2. public Optional<List<Long>> evaluate(final Query query) {
  3.   if (latestRecords.getSize() < query.getMaxResults()) {
  4.     return Optional.empty();
  5.   }
  6.   if (query.getSearchTerms().isEmpty() && query.getStartDate() == null && query.getEndDate() == null) {
  7.     final List<Long> eventList = latestRecords.asList();
  8.     if (eventList.size() > query.getMaxResults()) {
  9.       return Optional.of(eventList.subList(0, query.getMaxResults()));
  10.     } else {
  11.       return Optional.of(eventList);
  12.     }
  13.   } else {
  14.     return Optional.empty();
  15.   }
  16. }

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

  1. if (matchingRecords.size() > query.getMaxResults()) {
  2.   final Iterator<ProvenanceEventRecord> itr = matchingRecords.iterator();
  3.   for (int i = 0; i < query.getMaxResults(); i++) {
  4.     itr.next();
  5. updateExpiration();
  6. if (numCompletedSteps >= numSteps || this.matchingRecords.size() >= query.getMaxResults()) {
  7.   final long searchNanos = System.nanoTime() - creationNanos;
  8.   queryTime = TimeUnit.MILLISECONDS.convert(searchNanos, TimeUnit.NANOSECONDS);

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

  1. @Override
  2. public Optional<List<Long>> evaluate(final Query query) {
  3.   if (query.getMaxResults() > 1000) {
  4.     // If query max results > 1000 then we know we don't have enough results. So just return empty.
  5.     return Optional.empty();
  6.   }
  7.   final List<SearchTerm> terms = query.getSearchTerms();
  8.   if (terms.size() != 1) {
  9.     return Optional.empty();
  10.   }
  11.   final SearchTerm term = terms.get(0);
  12.   if (!COMPONENT_ID_FIELD_NAME.equals(term.getSearchableField().getSearchableFieldName())) {
  13.     return Optional.empty();
  14.   }
  15.   if (query.getEndDate() != null || query.getStartDate() != null) {
  16.     return Optional.empty();
  17.   }
  18.   final RingBuffer<Long> ringBuffer = latestRecords.get(term.getValue());
  19.   if (ringBuffer == null || ringBuffer.getSize() < query.getMaxResults()) {
  20.     return Optional.empty();
  21.   }
  22.   List<Long> eventIds = ringBuffer.asList();
  23.   if (eventIds.size() > query.getMaxResults()) {
  24.     eventIds = eventIds.subList(0, query.getMaxResults());
  25.   }
  26.   return Optional.of(eventIds);
  27. }

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

  1. final int maxResults = query.getMaxResults();
  2. final long startIndex = Math.max(maxEventId - query.getMaxResults(), 0L);

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

  1. @Override
  2. public QuerySubmission submitQuery(final Query query, final NiFiUser user) {
  3.   if (query.getEndDate() != null && query.getStartDate() != null && query.getStartDate().getTime() > query.getEndDate().getTime()) {
  4.     throw new IllegalArgumentException("Query End Time cannot be before Query Start Time");
  5.   }
  6.   final String userId = user == null ? null : user.getIdentity();
  7.   if (query.getSearchTerms().isEmpty() && query.getStartDate() == null && query.getEndDate() == null) {
  8.     final AsyncQuerySubmission result = new AsyncQuerySubmission(query, 1, userId);
  9.     queryExecService.submit(new QueryRunnable(ringBuffer, createFilter(query, user), query.getMaxResults(), result));
  10.     querySubmissionMap.put(query.getIdentifier(), result);
  11.     return result;
  12.   }
  13.   final AsyncQuerySubmission result = new AsyncQuerySubmission(query, 1, userId);
  14.   querySubmissionMap.put(query.getIdentifier(), result);
  15.   queryExecService.submit(new QueryRunnable(ringBuffer, createFilter(query, user), query.getMaxResults(), result));
  16.   return result;
  17. }

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

  1. public StandardQueryResult search(final org.apache.nifi.provenance.search.Query provenanceQuery, final NiFiUser user, final AtomicInteger retrievedCount,
  2.   final long firstEventTimestamp) throws IOException {
  3.   if (retrievedCount.get() >= provenanceQuery.getMaxResults()) {
  4.     final StandardQueryResult sqr = new StandardQueryResult(provenanceQuery, 1);
  5.     sqr.update(Collections.<ProvenanceEventRecord> emptyList(), 0L);
  6.       indexDirectory, provenanceQuery, provenanceQuery.getMaxResults());
  7.     final TopDocs topDocs = searcher.getIndexSearcher().search(luceneQuery, provenanceQuery.getMaxResults());
  8.     final long finishSearch = System.nanoTime();
  9.     final long searchNanos = finishSearch - searchStartNanos;
  10.       provenanceQuery.getMaxResults(), maxAttributeChars);

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

  1. final AsyncQuerySubmission result = new AsyncQuerySubmission(query, 1, userId);
  2. if (latestRecords.getSize() >= query.getMaxResults()) {
  3.   final List<ProvenanceEventRecord> latestList = filterUnauthorizedEvents(latestRecords.asList(), user);
  4.   final List<ProvenanceEventRecord> trimmed;
  5.   if (latestList.size() > query.getMaxResults()) {
  6.     trimmed = latestList.subList(latestList.size() - query.getMaxResults(), latestList.size());
  7.   } else {
  8.     trimmed = latestList;

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

  1. queryExecutor.submit(new QueryTask(luceneQuery, submission.getResult(), query.getMaxResults(), indexManager, indexDir,
  2.   eventStore, authorizer, EventTransformer.EMPTY_TRANSFORMER));

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

  1. requestDto.setMinimumFileSize(query.getMinFileSize());
  2. requestDto.setMaximumFileSize(query.getMaxFileSize());
  3. requestDto.setMaxResults(query.getMaxResults());
  4. if (query.getSearchTerms() != null) {
  5.   final Map<String, String> searchTerms = new HashMap<>();

代码示例来源：origin: org.apache.nifi/nifi-data-provenance-utils

  1. @Override
  2. public boolean isFinished() {
  3.   readLock.lock();
  4.   try {
  5.     return numCompletedSteps >= numSteps || canceled || matchingRecords.size() >= query.getMaxResults();
  6.   } finally {
  7.     readLock.unlock();
  8.   }
  9. }

代码示例来源：origin: org.apache.nifi/nifi-data-provenance-utils

  1. @Override
  2. public long getTotalHitCount() {
  3.   readLock.lock();
  4.   try {
  5.     // Because we filter the results based on the user's permissions,
  6.     // we don't want to indicate that the total hit count is 1,000+ when we
  7.     // have 0 matching records, for instance. So, if we have fewer matching
  8.     // records than the max specified by the query, it is either the case that
  9.     // we truly don't have enough records to reach the max results, or that
  10.     // the user is not authorized to see some of the results. Either way,
  11.     // we want to report the number of events that we find AND that the user
  12.     // is allowed to see, so we report matching record count, or up to max results.
  13.     if (matchingRecords.size() < query.getMaxResults()) {
  14.       return matchingRecords.size();
  15.     } else {
  16.       return query.getMaxResults();
  17.     }
  18.   } finally {
  19.     readLock.unlock();
  20.   }
  21. }

代码示例来源：origin: org.apache.nifi/nifi-data-provenance-utils

  1. if (matchingRecords.size() > query.getMaxResults()) {
  2.   final Iterator<ProvenanceEventRecord> itr = matchingRecords.iterator();
  3.   for (int i = 0; i < query.getMaxResults(); i++) {
  4.     itr.next();
  5. updateExpiration();
  6. if (numCompletedSteps >= numSteps || this.matchingRecords.size() >= query.getMaxResults()) {
  7.   final long searchNanos = System.nanoTime() - creationNanos;
  8.   queryTime = TimeUnit.MILLISECONDS.convert(searchNanos, TimeUnit.NANOSECONDS);

代码示例来源：origin: apache/nifi-minifi

  1. final int maxResults = query.getMaxResults();
  2. final long startIndex = Math.max(maxEventId - query.getMaxResults(), 0L);

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

query

相关文章

    查看更多

    热门标签

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

    最新文章

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