Hazelcast Jet SourceProcessors Sınıfı - ProcessorMetaSupplier Yaratır

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.core.processor.SourceProcessors;

Bu sınıf ProcessorMetaSupplier döndüren bir sürü metod sağlıyor.

readMapP metodu

İmzası şöyle

public static ProcessorMetaSupplier readMapP(String mapName);

İsmi belirtilen IMap nesnesini okumak içindir

streamMapP metodu

İmzası şöyle

public static <K, V> ProcessorMetaSupplier streamMapP(
  String mapName,
  JournalInitialPosition initialPos,
  EventTimePolicy<? super Entry<K, V>> eventTimePolicy
)

İsmi belirtilen IMap nesnesine yapılan değişklikleri yani Journal event'lerini okur