Hazelcast Jet JobRepository Sınıfı - Light Olmayan Job'ları Saklar

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.impl.JobRepository;

constructor

Kodu şöyle. Yani JobRecord nesneleri de bir IMap üzerinde saklanır

public class JobRepository {

  private final HazelcastInstance instance;
  private final ILogger logger;

  private final ConcurrentMemoizingSupplier<IMap<Long, JobRecord>> jobRecords;
  private final ConcurrentMemoizingSupplier<IMap<Long, JobResult>> jobResults;
  private final Supplier<IMap<Long, JobExecutionRecord>> jobExecutionRecords;
  private final Supplier<IMap<Long, List<RawJobMetrics>>> jobMetrics;
  private final Supplier<IMap<String, SnapshotValidationRecord>> 
    exportedSnapshotDetailsCache;
  private final Supplier<FlakeIdGenerator> idGenerator;
  ...
}

getJobRecord metodu - long jobId

Belirtilen ID'ye sahip JobRecord  nesnesini döner.