Hazelcast Jet StreamEventJournalP Sınıfı - Source

Giriş
Şu satırı dahil ederiz 

import com.hazelcast.jet.impl.connector.StreamEventJournalP;

Kalıtım şöyle

Processor
  AbstractProcessor
    StreamEventJournalP

Bu sınıfın içinde ki tane sınıf daha var

1. private static class ClusterMetaSupplier<E, T> implements ProcessorMetaSupplier - Yani bir ProcessorMetaSupplier ve Processor yaratır

2. private static class ClusterProcessorSupplier<E, T> implements ProcessorSupplier {

streamMapSupplier metodu

Çağrı sırası şöyle

Sources.streamMapP()
  StreamEventJournalP.streamMapSupplier()

streamRemoteMapSupplier metodu

Çağrı sırası şöyle

Sources.remoteMapJournal()
  StreamEventJournalP.streamRemoteMapSupplier()

Bir ClusterMetaSupplier nesnesi döner.