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

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

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

@Override
public String getQueryIdentifier() {
  return query.getIdentifier();
}

代码示例来源: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

if (eventIdListOption.isPresent()) {
    final AsyncQuerySubmission submission = new AsyncQuerySubmission(query, 1, userId);
    querySubmissionMap.put(query.getIdentifier(), submission);
querySubmissionMap.put(query.getIdentifier(), submission);
logger.debug("Submitting query {} with identifier {} against index directories {}", luceneQuery, query.getIdentifier(), indexDirectories);

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

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

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

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

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

@Override
public String getQueryIdentifier() {
  return query.getIdentifier();
}

相关文章