Hazelcast Jet JobProxy Sınıfı

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.impl.JobProxy;

invokeOp metodu

Kodu şöyle. İşi her zaman Job Coordinator member'a gönderir.

private <T> CompletableFuture<T> invokeOp(Operation op) {
  return container()
    .getOperationService()
    .createInvocationBuilder(JetServiceBackend.SERVICE_NAME, op, coordinatorId())
    .invoke();
}