HazelcastAPI DataConnectionRef Sınıfı

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.pipeline.DataConnectionRef;

Bu sınıf Serializable ve Sources.XXX gibi metodlara parametre olarak geçiliyor.

dataConnectionRef metodu

Örnek

Şöyle yaparız

String mapName = ...;
StreamSource<Entry<String, Integer>> source = Sources.remoteMapJournal(
  mapName, 
  DataConnectionRef.dataConnectionRef(...), 
  JournalInitialPosition.START_FROM_OLDEST
);