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

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

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

Query.getIdentifier介绍

暂无

代码示例

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

  1. @Override
  2. public String getQueryIdentifier() {
  3. return query.getIdentifier();
  4. }

代码示例来源: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. if (eventIdListOption.isPresent()) {
  2. final AsyncQuerySubmission submission = new AsyncQuerySubmission(query, 1, userId);
  3. querySubmissionMap.put(query.getIdentifier(), submission);
  4. querySubmissionMap.put(query.getIdentifier(), submission);
  5. logger.debug("Submitting query {} with identifier {} against index directories {}", luceneQuery, query.getIdentifier(), indexDirectories);

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

  1. querySubmissionMap.put(query.getIdentifier(), result);
  2. return result;
  3. query.getEndDate() == null ? null : query.getEndDate().getTime());
  4. final AsyncQuerySubmission result = new AsyncQuerySubmission(query, indexDirectories.size(), userId);
  5. querySubmissionMap.put(query.getIdentifier(), result);

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

  1. provenanceDto.setId(query.getIdentifier());
  2. provenanceDto.setSubmissionTime(querySubmission.getSubmissionTime());
  3. provenanceDto.setExpiration(queryResult.getExpiration());

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

  1. @Override
  2. public String getQueryIdentifier() {
  3. return query.getIdentifier();
  4. }

相关文章