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

QueryObserverHolder.setInstance介绍

[英]Set the given observer to be notified of query events. Returns the current observer.
[中]将给定的观察者设置为收到查询事件的通知。返回当前观察者。

代码示例

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

@Override
 public void run2() throws CacheException
 {
  class MyQueryObserver extends IndexTrackingQueryObserver {
   @Override
   public void startQuery(Query query) {
    throw new RuntimeException("For testing purpose only from remote node");
   }              
  };
  QueryObserverHolder.setInstance(new MyQueryObserver());
 };
}

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

@Override
 public void run2() throws CacheException
 {
  class MyQueryObserver extends IndexTrackingQueryObserver {
   @Override
   public void startQuery(Query query) {
    throw new RuntimeException("For testing purpose only from remote node");
   }              
  };
  QueryObserverHolder.setInstance(new MyQueryObserver());
 };
}

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

@Override
 public Object call() throws Exception {
  QueryObserver observer = QueryObserverHolder
    .setInstance(new QueryResultTrackingObserver());
  return observer;
 }
});

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

@Override
 public Object call() throws Exception {
  QueryObserver observer = QueryObserverHolder
    .setInstance(new QueryResultTrackingObserver());
  return observer;
 }
});

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

@Override
 public Object call() throws Exception {
  QueryObserver observer = QueryObserverHolder
    .setInstance(new QueryResultTrackingObserver());
  return observer;
 }
});

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

@Override
 public Object call() throws Exception {
  QueryObserver observer = QueryObserverHolder
    .setInstance(new QueryResultTrackingObserver());
  return observer;
 }
});

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

@Override
 public Object call() throws Exception {
  QueryObserver observer = QueryObserverHolder
    .setInstance(new QueryResultTrackingObserver());
  return observer;
 }
});

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

public synchronized static void HydraTask_attachQueryObserver() {
 QueryObserverImplBB observer = new QueryObserverImplBB();
 QueryObserverHolder.setInstance(observer);
}

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

public synchronized static void HydraTask_attachQueryObserver() {
 QueryObserverImpl observer = new QueryObserverImpl();
 QueryObserverHolder.setInstance(observer);
}

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

@Override
 public Object call() throws Exception {
  QueryObserver observer = QueryObserverHolder
    .setInstance(new QueryResultTrackingObserver());
  return observer;
 }
});

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

@Override
protected void setUp() throws Exception {
 System.setProperty("gemfire.Query.VERBOSE", "true");
 CacheUtils.startCache();
 QueryObserver observer = QueryObserverHolder.setInstance(new IndexTrackingQueryObserver());
}

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

public void run() {
  QueryObserverHolder.setInstance(new QueryObserverAdapter());
  stopBridgeServer(getCache());
 }
});

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

protected void setUp() throws java.lang.Exception {
 CacheUtils.startCache();
 qs = CacheUtils.getQueryService();
 observer = new MyQueryObserverAdapter();
 QueryObserverHolder.setInstance(observer);
 
}

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

public void run() {
  QueryObserverHolder.setInstance(new QueryObserverAdapter());
  stopBridgeServer(getCache());
 }
});

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

public void run() {
  QueryObserverHolder.setInstance(new QueryObserverAdapter());
  stopBridgeServer(getCache());
 }
});

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

public void testBeforeAndAfterCutDownAndExpansionOfSingleIndexResult( ){
 try {
 Query query = qs.newQuery("select distinct * from /portfolio p, p.positions where p.ID = 1  ");
 qs.createIndex("idIndex", IndexType.FUNCTIONAL, "ID", "/portfolio");
 MyQueryObserverImpl inst = new MyQueryObserverImpl();
 QueryObserverHolder.setInstance(inst);
 query.execute();
 assertTrue("beforeCutDownAndExpansionOfSingleIndexResult callbak not received",inst.bfrCutDownAndExpansionOfSingleIndexResult);
 assertTrue("afterCutDownAndExpansionOfSingleIndexResult callbak not received",inst.aftCutDownAndExpansionOfSingleIndexResult);
 }catch(Exception e) {
  e.printStackTrace();
  fail(e.toString());
 }
}

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

public void run() {
  System.setProperty("gemfire.Query.VERBOSE", "true");
  QueryObserver observer = QueryObserverHolder.setInstance(new IndexTrackingQueryObserver());
  
  //Create Partition Region
  PartitionAttributesFactory paf = new PartitionAttributesFactory();
  paf.setTotalNumBuckets(NUM_BKTS);
  AttributesFactory af = new AttributesFactory();
  af.setPartitionAttributes(paf.create());
  Region region = getCache().createRegion("portfolio", af.create());
  
 }
};

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

private void helpTestIndexForQuery(String query, String indexedExpression, String regionPath) throws Exception {
 QueryService qs = CacheUtils.getQueryService();
 QueryObserverImpl observer = new QueryObserverImpl();
 QueryObserverHolder.setInstance(observer);
 SelectResults nonIndexedResults = (SelectResults)qs.newQuery(query).execute();
 assertFalse(observer.isIndexesUsed);
 qs.createIndex("newIndex", indexedExpression, regionPath);
 SelectResults indexedResults = (SelectResults)qs.newQuery(query).execute();
 assertEquals(nonIndexedResults.size(), indexedResults.size());
 assertTrue(observer.isIndexesUsed);
}

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

private SelectResults helpTestIndexForQuery(String query, String indexedExpression, String regionPath, Object[] params) throws Exception {
 QueryService qs = CacheUtils.getQueryService();
 MyQueryObserverAdapter observer = new MyQueryObserverAdapter();
 QueryObserverHolder.setInstance(observer);
 SelectResults nonIndexedResults = (SelectResults)qs.newQuery(query).execute(params);
 assertFalse(observer.indexUsed);
 qs.createIndex("newIndex", indexedExpression, regionPath);
 SelectResults indexedResults = (SelectResults)qs.newQuery(query).execute(params);
 assertEquals(nonIndexedResults.size(), indexedResults.size());
 assertTrue(observer.indexUsed);
 return indexedResults;
}

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

private SelectResults helpTestFunctionalIndexForQuery(String query, String indexedExpression, String regionPath) throws Exception {
  MyQueryObserverAdapter observer = new MyQueryObserverAdapter();
 QueryObserverHolder.setInstance(observer);
 
 QueryService qs = CacheUtils.getQueryService();
 SelectResults nonIndexedResults = (SelectResults)qs.newQuery(query).execute();
 assertFalse(observer.indexUsed);
 Index index = qs.createIndex("testIndex", indexedExpression, regionPath);
 SelectResults indexedResults = (SelectResults)qs.newQuery(query).execute();
 assertEquals(nonIndexedResults.size(), indexedResults.size());
 assertTrue(observer.indexUsed);
 qs.removeIndex(index);
 return indexedResults;
}