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

Query介绍

[英]A Query instance transforms an input node set into an output node set.

Useful implementations will normally perform a sequence of graph traversal and node filtering operations to generate the query result.
[中]查询实例将输入节点集转换为输出节点集。
有用的实现通常会执行一系列图遍历和节点过滤操作来生成查询结果。

代码示例

代码示例来源：origin: ehcache/ehcache3

/**
 * Search for a statistic on the descendant of the context that matches the tag and statistic name.
 *
 * @param context the context of the query
 * @param tag the tag we are looking for
 * @param statName statistic name
 * @param <T> type of the statistic that will be returned
 * @return the wanted statistic or null if no such statistic is found
 * @throws RuntimeException when more than one matching statistic is found
 */
public static <T> Optional<T> findStatisticOnDescendants(Object context, String tag, String statName) {
 @SuppressWarnings("unchecked")
 Set<TreeNode> statResult = queryBuilder()
  .descendants()
  .filter(context(attributes(Matchers.allOf(
   hasAttribute("name", statName),
   hasTag(tag)))))
  .build().execute(Collections.singleton(ContextManager.nodeFor(context)));
 if (statResult.size() > 1) {
  throw new RuntimeException("One stat expected for " + statName + " but found " + statResult.size());
 }
 if (statResult.size() == 1) {
  @SuppressWarnings("unchecked")
  T result = (T) statResult.iterator().next().getContext().attributes().get("this");
  return Optional.ofNullable(result);
 }
 // No such stat in this context
 return Optional.empty();
}

代码示例来源：origin: ehcache/ehcache3

.build();
Set<TreeNode> statResult = statQuery.execute(Collections.singleton(ContextManager.nodeFor(cache)));

代码示例来源：origin: ehcache/ehcache3

/**
 * Find an operation statistic attached (as a children) to this context that matches the statistic name and type
 *
 * @param context the context of the query
 * @param type type of the operation statistic
 * @param statName statistic name
 * @param <T> type of the operation statistic content
 * @return the operation statistic searched for
 * @throws RuntimeException if 0 or more than 1 result is found
 */
public static <T extends Enum<T>> OperationStatistic<T> findOperationStatisticOnChildren(Object context, Class<T> type, String statName) {
 @SuppressWarnings("unchecked")
 Query query = queryBuilder()
  .children()
  .filter(context(attributes(Matchers.allOf(hasAttribute("name", statName), hasAttribute("type", type)))))
  .build();
 Set<TreeNode> result = query.execute(Collections.singleton(ContextManager.nodeFor(context)));
 if (result.size() > 1) {
  throw new RuntimeException("result must be unique");
 }
 if (result.isEmpty()) {
  throw new RuntimeException("result must not be null");
 }
 @SuppressWarnings("unchecked")
 OperationStatistic<T> statistic = (OperationStatistic<T>) result.iterator().next().getContext().attributes().get("this");
 return statistic;
}

代码示例来源：origin: ehcache/ehcache3

hasProperty("discriminator", discriminator),
 hasTag(tag)))))
.build().execute(Collections.singleton(ContextManager.nodeFor(context)));

代码示例来源：origin: ehcache/ehcache3

public static <T extends Enum<T>> boolean hasOperationStat(Object rootNode, Class<T> statisticType, String statName) {
  Query q = queryBuilder().descendants()
   .filter(context(identifier(subclassOf(OperationStatistic.class))))
   .filter(context(attributes(Matchers.allOf(
    hasAttribute("name", statName),
    hasAttribute("this", new Matcher<OperationStatistic<T>>() {
     @Override
     protected boolean matchesSafely(OperationStatistic<T> object) {
      return object.type().equals(statisticType);
     }
    })
   ))))
   .build();

  Set<TreeNode> result = q.execute(Collections.singleton(ContextManager.nodeFor(rootNode)));

  if (result.size() > 1) {
   throw new RuntimeException("a zero or a single stat was expected; found " + result.size());
  }

  return !result.isEmpty();
 }
}

代码示例来源：origin: net.sf.ehcache/ehcache

/**
   * {@inheritDoc}
   */
  @Override
  public Set<TreeNode> execute(Set<TreeNode> input) {
    return query.execute(input);
  }
}

代码示例来源：origin: net.sf.ehcache/ehcache

@Override
public final Set<TreeNode> execute(Set<TreeNode> input) {
 return current.execute(previous.execute(input));
}

代码示例来源：origin: ehcache/ehcache3

@SuppressWarnings("unchecked")
private static <T extends Enum<T>> OperationStatistic<T> findStat(Cache<?, ?> cache, final String statName, final String tag) {
 Query q = queryBuilder().chain(self())
   .descendants().filter(context(identifier(subclassOf(OperationStatistic.class)))).build();
 Set<TreeNode> operationStatisticNodes = q.execute(Collections.singleton(ContextManager.nodeFor(cache)));
 Set<TreeNode> result = queryBuilder()
   .filter(
     context(attributes(Matchers.<Map<String, Object>>allOf(
       hasAttribute("name", statName), hasAttribute("tags", new Matcher<Set<String>>() {
        @Override
        protected boolean matchesSafely(Set<String> object) {
         return object.contains(tag);
        }
       }))))).build().execute(operationStatisticNodes);
 switch (result.size()) {
  case 0:
   return null;
  case 1: {
   TreeNode node = result.iterator().next();
   return (OperationStatistic<T>) node.getContext().attributes().get("this");
  }
  default:
   throw new RuntimeException("query for unique stat '" + statName + "' with tag '" + tag + "' failed; found " + result.size() + " instance(s)");
 }
}

代码示例来源：origin: net.sf.ehcache/ehcache

@Override
public Set<TreeNode> execute(Set<TreeNode> input) {
 Set<TreeNode> descendants = new HashSet<TreeNode>();
 for (Set<TreeNode> children = Children.INSTANCE.execute(input); !children.isEmpty(); children = Children.INSTANCE.execute(children)) {
  if (!descendants.addAll(children)) {
   break;
  }
 }
 return descendants;
}

代码示例来源：origin: ehcache/ehcache3

@Test
 public void testStatisticsAssociations() throws Exception {
  OffHeapDiskStore.Provider provider = new OffHeapDiskStore.Provider();
 ServiceLocator serviceLocator = dependencySet().with(mock(SerializationProvider.class))
  .with(new DefaultTimeSourceService(null)).with(mock(DiskResourceService.class)).build();
 provider.start(serviceLocator);
 OffHeapDiskStore<Long, String> store = provider.createStore(getStoreConfig(), mock(PersistableResourceService.PersistenceSpaceIdentifier.class));
 @SuppressWarnings("unchecked")
 Query storeQuery = queryBuilder()
  .children()
  .filter(context(attributes(Matchers.allOf(
   hasAttribute("tags", new Matcher<Set<String>>() {
    @Override
    protected boolean matchesSafely(Set<String> object) {
     return object.contains("Disk");
    }
   })))))
  .build();
  Set<TreeNode> nodes = singleton(ContextManager.nodeFor(store));
  Set<TreeNode> storeResult = storeQuery.execute(nodes);
  assertThat(storeResult, not(empty()));
  provider.releaseStore(store);
  storeResult = storeQuery.execute(nodes);
  assertThat(storeResult, empty());
 }

代码示例来源：origin: ehcache/ehcache3

@SuppressWarnings("unchecked")
private Set<TreeNode> queryProperty(String key, String value) {
 Query statQuery = queryBuilder()
  .descendants()
  .filter(context(attributes(Matchers.<Map<String, Object>>allOf(
   hasAttribute("name", "test"),
   hasProperty(key, value)
  ))))
  .build();
 return statQuery.execute(Collections.singleton(ContextManager.nodeFor(cache)));
}

代码示例来源：origin: ehcache/ehcache3

private Set<TreeNode> queryProperty(String tag) {
 @SuppressWarnings("unchecked")
 Query statQuery = queryBuilder()
  .descendants()
  .filter(context(attributes(Matchers.<Map<String, Object>>allOf(
   hasAttribute("name", "get"),
   hasTag(tag)
  ))))
  .build();
 return statQuery.execute(Collections.singleton(ContextManager.nodeFor(cache)));
}

代码示例来源：origin: net.sf.ehcache/ehcache

/**
 * Run the supplied {@code Query} against this {@code ContextManager}'s 
 * root context.
 * <p>
 * The initial node in the queries traversal will be the node whose children
 * form the root set of this {@code ContextManager}.  That is, the following
 * code will select the root set of this instance.<br>
 * <pre>
 * public static Set<TreeNode> roots(ContextManager manager) {
 *   return manager.query(QueryBuilder.queryBuilder().children().build());
 * }
 * </pre>
 * 
 * @param query the query to execute
 * @return the set of nodes selected by the query
 */
public Set<TreeNode> query(Query query) {
 return query.execute(Collections.<TreeNode>singleton(root));
}

代码示例来源：origin: ehcache/ehcache3

.execute(singleton(nodeFor(cache)))
.iterator()
.next()

代码示例来源：origin: net.sf.ehcache/ehcache

return object.containsAll(tags);
}))))).build().execute(passThroughStatisticNodes);

代码示例来源：origin: org.sonatype.nexus.bundles/org.sonatype.nexus.bundles.ehcache

/**
   * {@inheritDoc}
   */
  @Override
  public Set<TreeNode> execute(Set<TreeNode> input) {
    return query.execute(input);
  }
}

代码示例来源：origin: net.sf.ehcache.internal/ehcache-core

/**
   * {@inheritDoc}
   */
  @Override
  public Set<TreeNode> execute(Set<TreeNode> input) {
    return query.execute(input);
  }
}

代码示例来源：origin: net.sf.ehcache/ehcache

return object.containsAll(tags);
}))))).build().execute(operationStatisticNodes);

代码示例来源：origin: org.terracotta/statistics

@Override
public final Set<TreeNode> execute(Set<TreeNode> input) {
 return current.execute(previous.execute(input));
}

代码示例来源：origin: org.terracotta.internal/statistics

@Override
public final Set<TreeNode> execute(Set<TreeNode> input) {
 return current.execute(previous.execute(input));
}