本文整理了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

@Override
public boolean isFinished() {
  readLock.lock();
  try {
    return numCompletedSteps >= numSteps || canceled || matchingRecords.size() >= query.getMaxResults();
  } finally {
    readLock.unlock();
  }
}

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

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

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

@Override
public Optional<List<Long>> evaluate(final Query query) {
  if (latestRecords.getSize() < query.getMaxResults()) {
    return Optional.empty();
  }
  if (query.getSearchTerms().isEmpty() && query.getStartDate() == null && query.getEndDate() == null) {
    final List<Long> eventList = latestRecords.asList();
    if (eventList.size() > query.getMaxResults()) {
      return Optional.of(eventList.subList(0, query.getMaxResults()));
    } else {
      return Optional.of(eventList);
    }
  } else {
    return Optional.empty();
  }
}

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

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

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

@Override
public Optional<List<Long>> evaluate(final Query query) {
  if (query.getMaxResults() > 1000) {
    // If query max results > 1000 then we know we don't have enough results. So just return empty.
    return Optional.empty();
  }
  final List<SearchTerm> terms = query.getSearchTerms();
  if (terms.size() != 1) {
    return Optional.empty();
  }
  final SearchTerm term = terms.get(0);
  if (!COMPONENT_ID_FIELD_NAME.equals(term.getSearchableField().getSearchableFieldName())) {
    return Optional.empty();
  }
  if (query.getEndDate() != null || query.getStartDate() != null) {
    return Optional.empty();
  }
  final RingBuffer<Long> ringBuffer = latestRecords.get(term.getValue());
  if (ringBuffer == null || ringBuffer.getSize() < query.getMaxResults()) {
    return Optional.empty();
  }
  List<Long> eventIds = ringBuffer.asList();
  if (eventIds.size() > query.getMaxResults()) {
    eventIds = eventIds.subList(0, query.getMaxResults());
  }
  return Optional.of(eventIds);
}

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

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

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

@Override
public QuerySubmission submitQuery(final Query query, final NiFiUser user) {
  if (query.getEndDate() != null && query.getStartDate() != null && query.getStartDate().getTime() > query.getEndDate().getTime()) {
    throw new IllegalArgumentException("Query End Time cannot be before Query Start Time");
  }
  final String userId = user == null ? null : user.getIdentity();
  if (query.getSearchTerms().isEmpty() && query.getStartDate() == null && query.getEndDate() == null) {
    final AsyncQuerySubmission result = new AsyncQuerySubmission(query, 1, userId);
    queryExecService.submit(new QueryRunnable(ringBuffer, createFilter(query, user), query.getMaxResults(), result));
    querySubmissionMap.put(query.getIdentifier(), result);
    return result;
  }
  final AsyncQuerySubmission result = new AsyncQuerySubmission(query, 1, userId);
  querySubmissionMap.put(query.getIdentifier(), result);
  queryExecService.submit(new QueryRunnable(ringBuffer, createFilter(query, user), query.getMaxResults(), result));
  return result;
}

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

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

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

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

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

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

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

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

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

@Override
public boolean isFinished() {
  readLock.lock();
  try {
    return numCompletedSteps >= numSteps || canceled || matchingRecords.size() >= query.getMaxResults();
  } finally {
    readLock.unlock();
  }
}

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

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

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

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

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

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