Hazelcast Jet Sources.remoteMapJournal metodu

Giriş

Bir başka cluster'daki belirtilen IMap'e ait EventJournalMapEvent olaylarını okur. Bu yüzden ClientConfig nesnesini geçmek gerekir. StreamSource nesnesi döner. 

Uzaktaki IMap nesnesinin event journal ayarlarının yapılmış olması gerekir

remoteMapJournal metodu - mapName + ClientConfig + JournalInitialPosition + projectionFn + predicateFn

Örnek

Şöyle yaparız. Örnekteki initialPosition parametresi yanlıştı. Bu parametre bu enumeration

JournalInitialPosition.START_FROM_OLDEST veya JournalInitialPosition.START_FROM_CURRENT

olmalı

Pipeline p = Pipeline.create();
p.drawFrom(Sources.<Integer, Integer, Integer>remoteMapJournal(MAP_NAME, 
    clientConfig,
    JournalInitialPosition.START_FROM_OLDEST, // initial position
    EventJournalMapEvent::getNewValue,        // projection
    true))                                    // predicate
  .peek()
  .drainTo(Sinks.list(SINK_NAME));