HazelcastAPI CP Subsystem IAtomicReference Arayüzü

Giriş

Şu satırı dahil ederiz

import com.hazelcast.cp.IAtomicReference;

Örnek

Şöyle yaparız

HazelcastInstance hazelcastInstance = Hazelcast.newHazelcastInstance();
CPSubsystem cpSubsystem = hazelcastInstance.getCPSubsystem();

IAtomicReference<String> atomicref = cpSubsystem.getAtomicReference("atomicref");
atomicref.set("value");

HazelcastAPI CP Subsystem FencedLock Arayüzü - Distributed Lock

Giriş

Şu satırı dahil ederiz

import com.hazelcast.cp.lock.FencedLock;

lock metodu

Örnek

Şöyle yaparız

HazelcastInstance hz =...;
// Get a distributed lock called "my-distributed-lock"
Lock lock = hz.getCPSubsystem().getLock("my-distributed-lock");
// Now create a lock and execute some guarded code.
lock.lock();
try {
  //do something here
} finally {
  lock.unlock();
}

tryLock metodu

Örnek

Şöyle yaparız

HazelcastInstance hazelcastInstance = Hazelcast.newHazelcastInstance();
CPSubsystem cpSubsystem = hazelcastInstance.getCPSubsystem();

FencedLock lock = cpSubsystem.getLock("lock");
lock.tryLock();

HazelcastAPI CP Subsystem ISemaphore Arayüzü

Giriş

Şu satırı dahil ederiz

import com.hazelcast.cp.ISemaphore;

acquire metodu - int permits

Belirtilen sayıdaki izni almaya çalışır

init metodu - int permits

Semaphore belirtilen sayıda izin ile ilklendirilir.

tryAcquire metodu

Örnek

Şöyle yaparız

HazelcastInstance hazelcastInstance = Hazelcast.newHazelcastInstance();
CPSubsystem cpSubsystem = hazelcastInstance.getCPSubsystem();

ISemaphore semaphore = cpSubsystem.getSemaphore("semaphore");
semaphore.tryAcquire();

Hazelcast Jet SqlConnector Arayüzü - İsmi HazelcastSqlConnector Olmalıydı

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.sql.impl.connector.SqlConnector;

Bu sınıfı CreateDagVisitor kullanıyor.

Kalıtım şöyle

SqlConnector

  SeriesSqlConnector

  FileSqlConnector

  InfoSchemaConnector

  IMapSqlConnector : CREATE MAPPING ... Type IMAP cümlesi sonucunda bu connector yaratılır

  JdbcSqlConnector : CREATE MAPPING ... Type JDBC cümlesi sonucunda bu connector yaratılır

  StreamSqlConnector

  KafkaSqlConnector : CREATE MAPPING ... Type KAFKA cümlesi sonucunda bu connector yaratılır

Hazelcast Jet HazelcastSqlOperatorTable Sınıfı

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.sql.impl.validate.HazelcastSqlOperatorTable;

Hazelcast SQL içindeki tüm operatörler burada tanımlı

Apache Calcite integration in Hazelcast In-Memory Data Grid videosu da faydalı

Hazelcast Jet DAG Sınıfı

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.core.DAG;

Kullanım

Örnek

Şöyle yaparız

DAG dag = new DAG();
Vertex producer =...
Vertex consumer = ...

dag.vertex(producer)
  .vertex(consumer)
   .edge(Edge.between(producer, consumer));

JetService jetService = ...
jetService.newJob(dag)

Açıklaması şöyle. Yani DAG sınıfını elle kodlamak yerine 

However, the programming paradigm for Hazelcast is the ‘Pipeline API’, which provides a simpler way of representing computations which Jet will automatically convert to DAG.

Yani DAG sınıfını elle kodlamak yerine Pipeline sınıfı kullanılıyor.

Pipeline p = Pipeline.create();

HazelcastAPI ICache Arayüzü - JSR 107 JCache Gerçekleştirimi

Giriş

Şu satırı dahil ederiz

import com.hazelcast.cache.ICache;

Kodu şöyle

import javax.cache.Cache;
import javax.cache.expiry.ExpiryPolicy;

public interface ICache<K, V>
        extends javax.cache.Cache<K, V>, PrefixedDistributedObject {
   ...
}