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();