Giriş
Şu satırı dahil ederiz
import org.apache.ignite.client.ClientCache;
Thick Client için IgniteCache kullanılır.
ContinuousQuery çalıştırır
query metodu - ContinuousQuery + ClientDisconnectListener
Örnek
Şöyle yaparız
ClientDisconnectListener disconnectListener = reason -> System.out.printf("Client: %s received disconnect event with reason:%s %n", getClientIpAddr(), reason.getMessage()); ContinuousQuery<String, String> continuousQuery = ... QueryCursor<Cache.Entry<String, String>> queryCursor = cache.query(continuousQuery, disconnectListener);
put metodu
Örnek
Şöyle yaparız
ClientCache<Integer, String> cache = ...; cache.put(1, "one"); cache.put(2, "two"); cache.put(3, "three");
putIfAbsent metodu
Unique constraint ile ilgili bir açıklama burada
Hiç yorum yok:
Yorum Gönder