Hazelcast Jet SubmitJobOperation Sınıfı

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.impl.operation.SubmitJobOperation;

Kalıtım şöyle

Operation

  AsyncOperation

    AsyncJobOperation

      SubmitJobOperation

doRun metodu

Kod şöyle. İşi JobCoordinationService nesnesine gönderiyor.

@Override
public CompletableFuture<Void> doRun() {
  JobConfig jobConfig = deserializedJobConfig != null ? deserializedJobConfig :
    getNodeEngine().getSerializationService().toObject(serializedJobConfig);
  if (isLightJob) {
    if (deserializedJobDefinition != null) {
      return getJobCoordinationService().submitLightJob(jobId(), 
        deserializedJobDefinition, null, jobConfig, subject);
    }
    return getJobCoordinationService().submitLightJob(jobId(), null, 
      serializedJobDefinition, jobConfig, subject);
  }
  // the jobDefinition for non-light job is always serialized
  assert deserializedJobDefinition == null; 
  return getJobCoordinationService().submitJob(jobId(), 
    serializedJobDefinition, jobConfig, subject);
}

protected JobCoordinationService getJobCoordinationService() {
  return getJetServiceBackend().getJobCoordinationService();
}