com.gemstone.gemfire.cache.query.internal.QueryObserverHolder.reset()方法的使用及代码示例

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

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

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();

相关文章