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

QueryObserverHolder.hasObserver介绍

暂无

代码示例

代码示例来源：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-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: 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: io.snappydata/gemfire-hydra-tests

assertTrue(QueryObserverHolder.hasObserver());
assertTrue(observer instanceof QueryResultTrackingObserver);
QueryResultTrackingObserver resultObserver = (QueryResultTrackingObserver) observer;

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

assertTrue(QueryObserverHolder.hasObserver());
assertTrue(observer instanceof QueryResultTrackingObserver);
QueryResultTrackingObserver resultObserver = (QueryResultTrackingObserver) observer;

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

assertTrue(QueryObserverHolder.hasObserver());
assertTrue(observer instanceof QueryResultTrackingObserver);
QueryResultTrackingObserver resultObserver = (QueryResultTrackingObserver) observer;

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

assertTrue(QueryObserverHolder.hasObserver());
assertTrue(observer instanceof QueryResultTrackingObserver);
QueryResultTrackingObserver resultObserver = (QueryResultTrackingObserver) observer;

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

assertTrue(QueryObserverHolder.hasObserver());
assertTrue(observer instanceof QueryResultTrackingObserver);
QueryResultTrackingObserver resultObserver = (QueryResultTrackingObserver) observer;

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

assertTrue(QueryObserverHolder.hasObserver());
assertTrue(observer instanceof QueryResultTrackingObserver);
QueryResultTrackingObserver resultObserver = (QueryResultTrackingObserver) observer;

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

indexObserver = (IndexTrackingQueryObserver)qo;
else if (!QueryObserverHolder.hasObserver()) {
 indexObserver = new IndexTrackingQueryObserver();
 QueryObserverHolder.setInstance(indexObserver);

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

indexObserver = (IndexTrackingQueryObserver)qo;
else if (!QueryObserverHolder.hasObserver()) {
 indexObserver = new IndexTrackingQueryObserver();
 QueryObserverHolder.setInstance(indexObserver);

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

assertTrue(QueryObserverHolder.hasObserver());

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

assertTrue(QueryObserverHolder.hasObserver());