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

QueryRequest介绍

[英]Query request attributes.
[中]查询请求属性。

代码示例

代码示例来源：origin: OpenNMS/opennms

private QueryResponse queryInt(final String resource, final String attribute, final long start, final long end, final long step, final String aggregation, final boolean relaxed) throws MeasurementException {
    QueryRequest request = new QueryRequest();
    request.setRelaxed(relaxed);
    request.setStart(start);
    request.setEnd(end);
    request.setStep(step);

    Source source = new Source();
    source.setAggregation(aggregation);
    source.setTransient(false);
    source.setAttribute(attribute);
    source.setResourceId(resource);
    source.setLabel(attribute);

    request.setSources(Collections.singletonList(source));

    return measurementsService.query(request);
  }
}

代码示例来源：origin: OpenNMS/opennms

@DefaultValue("false") @QueryParam("relaxed") final boolean relaxed) {
QueryRequest request = new QueryRequest();
request.setEnd(end > 0 ? end : new Date().getTime());
request.setStart(start >= 0 ? start : request.getEnd() + start);
if (request.getStart() < 0) {
  request.setStart(0);
request.setStep(step);
request.setMaxRows(maxrows);
request.setRelaxed(relaxed);
source.setFallbackAttribute(fallbackAttribute);
source.setAggregation(aggregation);
request.setSources(Lists.newArrayList(source));

代码示例来源：origin: OpenNMS/opennms

public void validate(QueryRequest request) throws ValidationException {
  if (request.getEnd() < 0) {
    throw new ValidationException("Query end must be >= 0: {}", request.getEnd());
  if (request.getStep() <= 0) {
    throw new ValidationException("Query step must be > 0: {}", request.getStep());
  if ((request.getHeartbeat() == null && request.getInterval() != null)
      || (request.getHeartbeat() != null && request.getInterval() == null)) {
    throw new ValidationException("If either the heartbeat or the interval are set, then both must be set.");
  if (request.getHeartbeat() != null && request.getInterval() != null) {
    if (request.getHeartbeat() <= 0) {
      throw new ValidationException("Heartbeat must be positive: {}", request.getHeartbeat());
    if (request.getInterval() <= 0) {
      throw new ValidationException("Interval must be positive: {}", request.getInterval());
    if (request.getStep() % request.getInterval() != 0) {
      throw new ValidationException("Step must be a multiple of the interval. Step: {}, Interval: {}",
          request.getStep(), request.getInterval());
    if (request.getHeartbeat() % request.getInterval() != 0) {
      throw new ValidationException("Heartbeat must be a multiple of the interval. Interval: {} Heartbeat: {}",
          request.getInterval(), request.getHeartbeat());
  for (final Source source : request.getSources()) {
    if (source.getResourceId() == null
        || source.getAttribute() == null

代码示例来源：origin: org.opennms.features.measurements/org.opennms.features.measurements.api

try {
  results = fetchStrategy.fetch(
      request.getStart(),
      request.getEnd(),
      request.getStep(),
      request.getMaxRows(),
      request.getHeartbeat(),
      request.getInterval(),
      request.getSources(),
      request.isRelaxed());
} catch (Exception e) {
  throw new FetchException(e, "Fetch failed: {}", e.getMessage());
if (!request.getFilters().isEmpty()) {
  RowSortedTable<Long, String, Double> table = results.asRowSortedTable();
  filterEngine.filter(request.getFilters(), table);
  results = new FetchResults(table, results.getStep(), results.getConstants());
for (final Source source : request.getSources()) {
  if (source.getTransient()) {
    columns.remove(source.getLabel());
response.setStart(request.getStart());
response.setEnd(request.getEnd());
response.setStep(results.getStep());
response.setTimestamps(results.getTimestamps());

代码示例来源：origin: OpenNMS/opennms

@Override
public JRRewindableDataSource createDataSource(String query) throws JRException {
  Objects.requireNonNull(query);
  QueryRequest queryRequest = unmarshal(query);
  Objects.requireNonNull(queryRequest);
  queryRequest.setRelaxed(true); // Enforce relaxed mode
  try {
    QueryResponse response = fetchService.query(queryRequest);
    return new MeasurementDataSource(response);
  } catch (ResourceNotFoundException rnfe) {
    LOG.warn("A attribute or resource was not found", rnfe);
    return new EmptyJRDataSource();
  } catch (Exception e) {
    LOG.error("An error occurred while fetching the measurement results", e);
    throw new JRException(e);
  }
}

代码示例来源：origin: OpenNMS/opennms

Preconditions.checkNotNull(results, "results argument");
final int numExpressions = request.getExpressions().size();
for (final Expression e : request.getExpressions()) {

代码示例来源：origin: OpenNMS/opennms

try {
  results = fetchStrategy.fetch(
      request.getStart(),
      request.getEnd(),
      request.getStep(),
      request.getMaxRows(),
      request.getHeartbeat(),
      request.getInterval(),
      request.getSources(),
      request.isRelaxed());
} catch (Exception e) {
  throw new FetchException(e, "Fetch failed: {}", e.getMessage());
if (!request.getFilters().isEmpty()) {
  RowSortedTable<Long, String, Double> table = results.asRowSortedTable();
  filterEngine.filter(request.getFilters(), table);
  results = new FetchResults(table, results.getStep(), results.getConstants(), results.getMetadata());
for (final Source source : request.getSources()) {
  if (source.getTransient()) {
    columns.remove(source.getLabel());
response.setStart(request.getStart());
response.setEnd(request.getEnd());
response.setStep(results.getStep());
response.setTimestamps(results.getTimestamps());

代码示例来源：origin: OpenNMS/opennms

try {
  QueryRequest queryRequest = unmarshal(query);
  queryRequest.setRelaxed(true); // enforce relaxed mode
  query = marshal(queryRequest);
  Result result = connector.execute(useSsl, url, username, password, query);

代码示例来源：origin: org.opennms.features.measurements/org.opennms.features.measurements.impl

Preconditions.checkNotNull(results, "results argument");
final int numExpressions = request.getExpressions().size();
for (final Expression e : request.getExpressions()) {

代码示例来源：origin: org.opennms.features.topology/org.opennms.features.topology.api

private QueryResponse queryInt(final String resource, final String attribute, final long start, final long end, final long step, final String aggregation, final boolean relaxed) throws MeasurementException {
    QueryRequest request = new QueryRequest();
    request.setRelaxed(relaxed);
    request.setStart(start);
    request.setEnd(end);
    request.setStep(step);

    Source source = new Source();
    source.setAggregation(aggregation);
    source.setTransient(false);
    source.setAttribute(attribute);
    source.setResourceId(resource);
    source.setLabel(attribute);

    request.setSources(Collections.singletonList(source));

    return measurementsService.query(request);
  }
}

代码示例来源：origin: org.opennms.features.measurements/org.opennms.features.measurements.api

public void validate(QueryRequest request) throws ValidationException {
  if (request.getEnd() < 0) {
    throw new ValidationException("Query end must be >= 0: {}", request.getEnd());
  if (request.getStep() <= 0) {
    throw new ValidationException("Query step must be > 0: {}", request.getStep());
  if ((request.getHeartbeat() == null && request.getInterval() != null)
      || (request.getHeartbeat() != null && request.getInterval() == null)) {
    throw new ValidationException("If either the heartbeat or the interval are set, then both must be set.");
  if (request.getHeartbeat() != null && request.getInterval() != null) {
    if (request.getHeartbeat() <= 0) {
      throw new ValidationException("Heartbeat must be positive: {}", request.getHeartbeat());
    if (request.getInterval() <= 0) {
      throw new ValidationException("Interval must be positive: {}", request.getInterval());
    if (request.getStep() % request.getInterval() != 0) {
      throw new ValidationException("Step must be a multiple of the interval. Step: {}, Interval: {}",
          request.getStep(), request.getInterval());
    if (request.getHeartbeat() % request.getInterval() != 0) {
      throw new ValidationException("Heartbeat must be a multiple of the interval. Interval: {} Heartbeat: {}",
          request.getInterval(), request.getHeartbeat());
  for (final Source source : request.getSources()) {
    if (source.getResourceId() == null
        || source.getAttribute() == null

代码示例来源：origin: OpenNMS/opennms

QueryRequest request = new QueryRequest();
request.setRelaxed(true);
request.setStart(start);
request.setEnd(end);
request.setStep(step);
sourceOut.setLabel("ifOutOctets");
request.setExpressions(Arrays.asList(new Expression("ifInPercent", "(8 * ifInOctects / 1000000) / ifInOctets.ifHighSpeed * 100", false), new Expression("ifOutPercent", "(8 * ifOutOctects / 1000000) / ifOutOctets.ifHighSpeed * 100", false)));
request.setSources(Arrays.asList(sourceIn, sourceOut));

代码示例来源：origin: org.opennms.features.topology/org.opennms.features.topology.api

QueryRequest request = new QueryRequest();
request.setRelaxed(true);
request.setStart(start);
request.setEnd(end);
request.setStep(step);
sourceOut.setLabel("ifOutOctets");
request.setExpressions(Arrays.asList(new Expression("ifInPercent", "(8 * ifInOctects / 1000000) / ifInOctets.ifHighSpeed * 100", false), new Expression("ifOutPercent", "(8 * ifOutOctects / 1000000) / ifOutOctets.ifHighSpeed * 100", false)));
request.setSources(Arrays.asList(sourceIn, sourceOut));