本文整理了Java中org.apache.nifi.provenance.search.Query.getIdentifier
方法的一些代码示例,展示了Query.getIdentifier
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Query.getIdentifier
方法的具体详情如下:
包路径:org.apache.nifi.provenance.search.Query
类名称: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();
}
内容来源于网络,如有侵权,请联系作者删除!