本文整理了Java中com.gemstone.gemfire.cache.query.internal.QueryObserverHolder.reset
方法的一些代码示例,展示了QueryObserverHolder.reset
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryObserverHolder.reset
方法的具体详情如下:
包路径:com.gemstone.gemfire.cache.query.internal.QueryObserverHolder
类名称:QueryObserverHolder
方法名:reset
[英]Only for test purposes.
[中]仅用于测试目的。
代码示例来源:origin: io.snappydata/gemfire-hydra-tests
@Override
public void run2() throws CacheException {
QueryObserverHolder.reset();
}
});
代码示例来源:origin: io.snappydata/gemfire-hydra-tests
@Override
public void run2() throws CacheException {
QueryObserverHolder.reset();
}
});
代码示例来源:origin: io.snappydata/gemfire-hydra-tests
@Override
public void run2() throws CacheException {
QueryObserverHolder.reset();
}
});
代码示例来源:origin: org.apache.geode/gemfire-core
}finally{
if(queryObserver!=null){
QueryObserverHolder.reset();
代码示例来源:origin: io.snappydata/gemfire-junit
QueryObserverHolder.reset();
代码示例来源:origin: io.snappydata/gemfire-junit
QueryObserverHolder.reset();
代码示例来源:origin: io.snappydata/gemfire-junit
public void testTraceOnLocalRegionWithTracePrefixNoComments() throws Exception{
String prefix = " <TRACE> ";
//Create Partition Region
AttributesFactory af = new AttributesFactory();
af.setScope(Scope.LOCAL);
region = CacheUtils.createRegion("portfolio", af.create(), false);
if (region.size() == 0) {
for (int i = 1; i <= 100; i++) {
region.put(Integer.toString(i), new Portfolio(i, i));
}
}
assertEquals(100, region.size());
qs = CacheUtils.getQueryService();
keyIndex1 = (IndexProtocol) qs.createIndex(INDEX_NAME,
IndexType.FUNCTIONAL, "ID", "/portfolio ");
assertTrue(keyIndex1 instanceof CompactRangeIndex);
Query query = qs.newQuery(prefix+queryStr);
assertTrue(((DefaultQuery)query).isTraced());
SelectResults results = (SelectResults)query.execute();
assertTrue(QueryObserverHolder.getInstance() instanceof IndexTrackingQueryObserver);
//The query should return all elements in region.
assertEquals(region.size(), results.size());
QueryObserverHolder.reset();
}
代码示例来源:origin: io.snappydata/gemfire-junit
public void testTraceOnLocalRegionWithSmallTracePrefixNoComments() throws Exception{
String prefix = "<trace> ";
//Create Partition Region
AttributesFactory af = new AttributesFactory();
af.setScope(Scope.LOCAL);
region = CacheUtils.createRegion("portfolio", af.create(), false);
if (region.size() == 0) {
for (int i = 1; i <= 100; i++) {
region.put(Integer.toString(i), new Portfolio(i, i));
}
}
assertEquals(100, region.size());
qs = CacheUtils.getQueryService();
keyIndex1 = (IndexProtocol) qs.createIndex(INDEX_NAME,
IndexType.FUNCTIONAL, "ID", "/portfolio ");
assertTrue(keyIndex1 instanceof CompactRangeIndex);
Query query = qs.newQuery(prefix+queryStr);
assertTrue(((DefaultQuery)query).isTraced());
SelectResults results = (SelectResults)query.execute();
assertTrue(QueryObserverHolder.getInstance() instanceof IndexTrackingQueryObserver);
//The query should return all elements in region.
assertEquals(region.size(), results.size());
QueryObserverHolder.reset();
}
代码示例来源:origin: io.snappydata/gemfire-junit
QueryObserverHolder.reset();
代码示例来源:origin: io.snappydata/gemfire-core
}finally{
if(queryObserver!=null){
QueryObserverHolder.reset();
代码示例来源:origin: io.snappydata/gemfire-junit
QueryObserverHolder.reset();
代码示例来源:origin: io.snappydata/gemfire-junit
QueryObserverHolder.reset();
代码示例来源:origin: io.snappydata/gemfire-junit
QueryObserverHolder.reset();
代码示例来源:origin: io.snappydata/gemfire-junit
QueryObserverHolder.reset();
代码示例来源:origin: io.snappydata/gemfire-junit
QueryObserverHolder.reset();
内容来源于网络,如有侵权,请联系作者删除!