Apache Ignite：連續SQLFieldQuery

我期待公開Apache Ignite Cache並且客戶端應用程序可以訪問相同的內容。我可以在Apache Ignite版本1.9中看到連續查詢支持 - https://github.com/apache/ignite/blob/master/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousAsyncQueryExample.java Apache Ignite：連續SQLFieldQuery

但是，我無法找到任何示例如何實現連續SQLFieldQuery。

public static void main(String[] args) throws Exception { 
     System.out.println("Run Spring example!!"); 
     Ignition.setClientMode(true); 
     IgniteConfiguration cfg = new IgniteConfiguration(); 
     cfg.setIncludeEventTypes(EVTS_CACHE); 
     cfg.setPeerClassLoadingEnabled(true); 
     TcpDiscoveryMulticastIpFinder discoveryMulticastIpFinder = new TcpDiscoveryMulticastIpFinder(); 
     Set<String> set = new HashSet<>(); 

     set.add("serverhost:47500..47509"); 
     discoveryMulticastIpFinder.setAddresses(set); 

     TcpDiscoverySpi discoverySpi = new TcpDiscoverySpi(); 
     discoverySpi.setIpFinder(discoveryMulticastIpFinder); 

     cfg.setDiscoverySpi(discoverySpi); 

     cfg.setPeerClassLoadingEnabled(true); 
     cfg.setIncludeEventTypes(EVTS_CACHE); 
     Ignite ignite = Ignition.start(cfg); 

     CacheConfiguration<String, BinaryObject> cacheConfiguration = new CacheConfiguration<>(CACHE_NAME); 


     IgniteCache<String, BinaryObject> cache = ignite.getOrCreateCache(cacheConfiguration).withKeepBinary(); 


     QueryCursor<List<?>> query = cache.query(new SqlFieldsQuery("select Field1 from table1 where Field1='TEST'")); 
      List<List<?>> all = query.getAll(); 
      for (List<?> l : all) { 
       System.out.println(l); 
      } 


    }

來源

2017-03-28 Sushil

連續查詢僅基於謂詞，SQL在此不受支持。您可以提供一個遠程過濾器，將在服務器端每次更新時調用該過濾器。所有滿足過濾器的更新都將被批量處理併發送到調用本地監聽器的訂閱者。

詳情請參閱此頁：https://apacheignite.readme.io/docs/continuous-queries

來源

2017-03-28 17:53:03

Apache Ignite：連續SQLFieldQuery

回答

相關問題