HazelcastAPI EventJournalReader Arayüzü

Giriş

Şu satırı dahil ederiz

import com.hazelcast.internal.journal.EventJournalReader;

Kalıtı şöyle

EventJournalReader

  CacheProxy

  ClientCacheProxy

  ClientMapProxy : Proxy implementation of IMap

  MapProxyImpl

subscribeToEventJournal metodu - int partitionId

Açıklama yaz

readFromEventJournal metodu

Şöyle yaparız

int partitionId = 1;
CompletionStage completionStage1 = eventJournalReader.subscribeToEventJournal(partitionId);

CompletionStage completionStage12 = eventJournalReader.readFromEventJournal(offset, 1, 
  MAX_FETCH_SIZE, //128
  partitionId, 
  predicate, 
  projection);