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

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

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

QueryObserverHolder.getInstance介绍

[英]Return the current QueryObserver instance
[中]返回当前QueryObserver实例

代码示例

代码示例来源：origin: io.snappydata/gemfire-hydra-tests

@Override
 public Object call() throws Exception {
  QueryObserver observer = QueryObserverHolder.getInstance();
  assertTrue(QueryObserverHolder.hasObserver());
  assertTrue(observer instanceof QueryResultTrackingObserver);
  QueryResultTrackingObserver resultObserver = (QueryResultTrackingObserver) observer;
  assertTrue(resultObserver.isObjectSerialized());
  return null;
 }
});

代码示例来源：origin: io.snappydata/gemfire-hydra-tests

@Override
 public Object call() throws Exception {
  QueryObserver observer = QueryObserverHolder.getInstance();
  assertTrue(QueryObserverHolder.hasObserver());
  assertTrue(observer instanceof QueryResultTrackingObserver);
  QueryResultTrackingObserver resultObserver = (QueryResultTrackingObserver) observer;
  assertTrue(resultObserver.isObjectSerialized());
  return null;
 }
});

代码示例来源：origin: io.snappydata/gemfire-hydra-tests

@Override
 public Object call() throws Exception {
  QueryObserver observer = QueryObserverHolder.getInstance();
  assertTrue(QueryObserverHolder.hasObserver());
  assertTrue(observer instanceof QueryResultTrackingObserver);
  QueryResultTrackingObserver resultObserver = (QueryResultTrackingObserver) observer;
  assertTrue(resultObserver.isObjectSerialized());
  return null;
 }
});

代码示例来源：origin: io.snappydata/gemfire-hydra-tests

@Override
 public Object call() throws Exception {
  QueryObserver observer = QueryObserverHolder.getInstance();
  assertTrue(QueryObserverHolder.hasObserver());
  assertTrue(observer instanceof QueryResultTrackingObserver);
  QueryResultTrackingObserver resultObserver = (QueryResultTrackingObserver) observer;
  assertTrue(resultObserver.isObjectSerialized());
  return null;
 }
});

代码示例来源：origin: io.snappydata/gemfire-junit

public void hook(int spot) throws RuntimeException {
 QueryObserver observer = QueryObserverHolder.getInstance();
 assertTrue(observer instanceof IndexTrackingQueryObserver);
 IndexTrackingQueryObserver gfObserver = (IndexTrackingQueryObserver)observer;
 
 if (spot == 1) { //before index lookup
 } else if (spot == 2) { //before key range index lookup
 } else if (spot == 3) { //End of afterIndexLookup call
 } else if (spot == 4) { //Before resetting indexInfoMap
  Map map = gfObserver.getUsedIndexes();
  assertEquals(1, map.size());
  
  assertTrue(map.get(INDEX_NAME) instanceof IndexInfo);
  rMap = (IndexInfo)map.get(INDEX_NAME);
  
  if(this.regn instanceof PartitionedRegion){
   assertEquals(1, rMap.getResults().size());
  } else if (this.regn instanceof LocalRegion) {
   assertEquals(1, rMap.getResults().size());
  }
 }
}

代码示例来源：origin: io.snappydata/gemfire-hydra-tests

@Override
 public Object call() throws Exception {
  QueryObserver observer = QueryObserverHolder.getInstance();
  assertTrue(QueryObserverHolder.hasObserver());
  assertTrue(observer instanceof QueryResultTrackingObserver);
  QueryResultTrackingObserver resultObserver = (QueryResultTrackingObserver) observer;
  assertFalse(resultObserver.isObjectSerialized());
  return null;
 }
});

代码示例来源：origin: io.snappydata/gemfire-hydra-tests

@Override
 public Object call() throws Exception {
  QueryObserver observer = QueryObserverHolder.getInstance();
  assertTrue(QueryObserverHolder.hasObserver());
  assertTrue(observer instanceof QueryResultTrackingObserver);
  QueryResultTrackingObserver resultObserver = (QueryResultTrackingObserver) observer;
  assertFalse(resultObserver.isObjectSerialized());
  return null;
 }
});

代码示例来源：origin: io.snappydata/gemfire-core

public Object call() throws Exception {
 BucketQueryResult bukResult = new BucketQueryResult(this._bucketId);
 boolean retry = false;
 try {
  //Add indexInfo of this thread to result collector
  QueryObserver observer = QueryObserverHolder.getInstance();
  if (observer != null && observer instanceof IndexTrackingQueryObserver) {
   //((IndexTrackingQueryObserver)observer).setIndexInfo(resultColl.getIndexInfoMap());
  }
  
  final Integer bId = Integer.valueOf(this._bucketId);
  ArrayList bucketList = new ArrayList();
  bucketList.add(this._bucketId);
  executeSequentially(this.resultColl, bucketList);
  // success
  //doBucketQuery(bId, this._prDs, this.query, this.parameters, this.resultColl);
 } catch (ForceReattemptException fre) {
  bukResult.setException(fre);
 } catch (QueryException e) {
  bukResult.setException(e);
 } catch (CacheRuntimeException cre) {
  bukResult.setException(cre);
 }
 // Exception
 return bukResult;
}

代码示例来源：origin: org.apache.geode/gemfire-core

public QueryObserver startTrace() {
 QueryObserver queryObserver = null;
 if (this.traceOn && this.cache != null) {
  QueryObserver qo = QueryObserverHolder.getInstance();
  if (qo instanceof IndexTrackingQueryObserver) {
   queryObserver = qo;
  } else if (!QueryObserverHolder.hasObserver()) {
   queryObserver = new IndexTrackingQueryObserver();
   QueryObserverHolder.setInstance(queryObserver);
  } else {
   queryObserver = qo;
  }
 }
 return queryObserver;
}

代码示例来源：origin: io.snappydata/gemfire-core

public QueryObserver startTrace() {
 QueryObserver queryObserver = null;
 if (this.traceOn && this.cache != null) {
  QueryObserver qo = QueryObserverHolder.getInstance();
  if (qo instanceof IndexTrackingQueryObserver) {
   queryObserver = qo;
  } else if (!QueryObserverHolder.hasObserver()) {
   queryObserver = new IndexTrackingQueryObserver();
   QueryObserverHolder.setInstance(queryObserver);
  } else {
   queryObserver = qo;
  }
 }
 return queryObserver;
}

代码示例来源：origin: io.snappydata/gemfire-hydra-tests

public void run() {
  //Query VERBOSE has to be true for the test
  assertEquals("true", System.getProperty("gemfire.Query.VERBOSE"));
 
  // Get TestHook from observer.
  QueryObserver observer = QueryObserverHolder.getInstance();
  assertTrue(QueryObserverHolder.hasObserver());
  final IndexTrackingTestHook th = (IndexTrackingTestHook) ((IndexTrackingQueryObserver) observer)
    .getTestHook();
  waitForCriterion(new WaitCriterion() {
   public boolean done() {
    return th.getRegionMap() != null;
   }
   public String description() {
    return null;
   }
  }, 5000, 200, false);
  IndexInfo regionMap = th.getRegionMap();
  Collection<Integer> rslts = regionMap.getResults().values();
  int totalResults = 0;
  for (Integer i : rslts) {
   totalResults += i.intValue();
  }
  
  getLogWriter().fine("Index Info result size is " + totalResults);
  assertEquals(results, totalResults);
 }
};

代码示例来源：origin: io.snappydata/gemfire-hydra-tests

public void run() {
 //Query VERBOSE has to be true for the test
  assertEquals("true", System.getProperty("gemfire.Query.VERBOSE"));
  
  QueryService qs = getCache().getQueryService();
  
  Index keyIndex1 = null;
  try {
   if(create){
    keyIndex1 = (IndexProtocol) qs.createIndex(IndexTrackingQueryObserverJUnitTest.INDEX_NAME,
     IndexType.FUNCTIONAL, "ID", "/portfolio ");
    assertNotNull(keyIndex1);
    assertTrue(keyIndex1 instanceof PartitionedIndex);
   }
  } catch (Exception e) {
   fail("While creating Index on PR", e);
  }
  Region region = getCache().getRegion("portfolio");
  //Inject TestHook in QueryObserver before running query.
  IndexTrackingTestHook th = new IndexTrackingTestHook(region, NUM_BKTS/2);
  QueryObserver observer = QueryObserverHolder.getInstance();
  assertTrue(QueryObserverHolder.hasObserver());
  
  ((IndexTrackingQueryObserver)observer).setTestHook(th);
 }
};

代码示例来源：origin: org.apache.geode/gemfire-core

public Object call() throws Exception {
 BucketQueryResult bukResult = new BucketQueryResult(this._bucketId);
 boolean retry = false;
 try {
  //Add indexInfo of this thread to result collector
  QueryObserver observer = QueryObserverHolder.getInstance();
  if (observer != null && observer instanceof IndexTrackingQueryObserver) {
   //((IndexTrackingQueryObserver)observer).setIndexInfo(resultColl.getIndexInfoMap());
  }
  
  final Integer bId = Integer.valueOf(this._bucketId);
  List<Integer> bucketList = Collections.singletonList(bId);       
  ExecutionContext context = new QueryExecutionContext(this.parameters, pr.getCache(), this.query);
  context.setBucketList(bucketList);
  executeQueryOnBuckets(this.resultColl, context);
  //executeSequentially(this.resultColl, bucketList);
  // success
  //doBucketQuery(bId, this._prDs, this.query, this.parameters, this.resultColl);
 } catch (ForceReattemptException fre) {
  bukResult.setException(fre);
 } catch (QueryException e) {
  bukResult.setException(e);
 } catch (CacheRuntimeException cre) {
  bukResult.setException(cre);
 }
 // Exception
 return bukResult;
}

代码示例来源：origin: org.apache.geode/gemfire-core

/**
 * Return a SelectResults that is the union of c1 and c2. May or may not
 * return a modified c1 or c2.
 */
public static SelectResults union(SelectResults c1,
                 SelectResults c2,
                 ExecutionContext contextOrNull) {
 QueryObserverHolder.getInstance().invokedQueryUtilsUnion(c1,c2);
 assertCompatible(c1, c2);
 // iterate on the smallest one
 if (c1.size() < c2.size()) {
  return sizeSortedUnion(c1, c2, contextOrNull);
 }
 else {
  return sizeSortedUnion(c2, c1, contextOrNull);
 }
}

代码示例来源：origin: io.snappydata/gemfire-core

/**
 * Return a SelectResults that is the union of c1 and c2. May or may not
 * return a modified c1 or c2.
 */
public static SelectResults union(SelectResults c1,
                 SelectResults c2,
                 ExecutionContext contextOrNull) {
 QueryObserverHolder.getInstance().invokedQueryUtilsUnion(c1,c2);
 assertCompatible(c1, c2);
 // iterate on the smallest one
 if (c1.size() < c2.size()) {
  return sizeSortedUnion(c1, c2, contextOrNull);
 }
 else {
  return sizeSortedUnion(c2, c1, contextOrNull);
 }
}

代码示例来源：origin: io.snappydata/gemfire-core

/**
 * Return a SelectResults that is the intersection of c1 and c2. May or may
 * not return a modified c1 or c2.
 */
public static SelectResults intersection(SelectResults c1,
                     SelectResults c2,
                     ExecutionContext contextOrNull) {
 QueryObserverHolder.getInstance().invokedQueryUtilsIntersection(c1,c2);
 assertCompatible(c1, c2);
 if (c1.isEmpty()) { return c1; }
 if (c2.isEmpty()) { return c2; }
 // iterate on the smallest one
 if (c1.size() < c2.size()) {
  return sizeSortedIntersection(c1, c2, contextOrNull);
 }
 else {
  return sizeSortedIntersection(c2, c1, contextOrNull);
 }
}

代码示例来源：origin: org.apache.geode/gemfire-core

/**
 * Return a SelectResults that is the intersection of c1 and c2. May or may
 * not return a modified c1 or c2.
 */
public static SelectResults intersection(SelectResults c1,
                     SelectResults c2,
                     ExecutionContext contextOrNull) {
 QueryObserverHolder.getInstance().invokedQueryUtilsIntersection(c1,c2);
 assertCompatible(c1, c2);
 if (c1.isEmpty()) { return c1; }
 if (c2.isEmpty()) { return c2; }
 // iterate on the smallest one
 if (c1.size() < c2.size()) {
  return sizeSortedIntersection(c1, c2, contextOrNull);
 }
 else {
  return sizeSortedIntersection(c2, c1, contextOrNull);
 }
}

代码示例来源：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

assertTrue(QueryObserverHolder.getInstance() instanceof IndexTrackingQueryObserver);

内容来源于网络，如有侵权，请联系作者删除！

QueryObserverHolder

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com