com.hazelcast.jet.Job.join()方法的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(6.5k)|赞(0)|评价(0)|浏览(102)

本文整理了Java中com.hazelcast.jet.Job.join()方法的一些代码示例，展示了Job.join()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Job.join()方法的具体详情如下：
包路径：com.hazelcast.jet.Job
类名称：Job
方法名：join

Job.join介绍

[英]Waits for the job to complete and throws an exception if the job completes with an error. Does not return if the job gets suspended. Never returns for streaming (unbounded) jobs, unless they fail or are cancelled.

Shorthand for job.getFuture().join().
[中]

代码示例

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

private long measure() throws InterruptedException, ExecutionException {
    System.out.print("\nCounting words... ");
    final Map<String, Long> counts = new ConcurrentHashMap<>();
    final Job job = jet.newJob(buildDag(counts));
    long start = System.nanoTime();
    job.join();
    final long took = TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - start);
    System.out.print("done in " + took + " milliseconds.");
//        printResults(counts);
    return took;
  }

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

private void buildInvertedIndex() {
  Job job = jet.newJob(createDag());
  long start = System.nanoTime();
  job.join();
  System.out.println("Indexing took " + NANOSECONDS.toMillis(System.nanoTime() - start) + " milliseconds.");
}

代码示例来源：origin: hazelcast/hazelcast-jet-demos

public void go() {
  System.out.print("\nStarting up... ");
  long start = System.nanoTime();
  Pipeline p = buildPipeline();
  jet.newJob(p).join();
  System.out.println("done in " + TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - start) + " milliseconds.");
}

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

private void buildInvertedIndex() {
  Job job = jet.newJob(createPipeline());
  long start = System.nanoTime();
  job.join();
  System.out.println("Indexing took " + NANOSECONDS.toMillis(System.nanoTime() - start) + " milliseconds.");
}

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

private static void runPipeline(JetInstance jet) {
    System.out.println("\nRunning the pipeline ");
    Pipeline p = buildPipeline();
    jet.newJob(p).join();
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet-demos

public static void main(String[] args) {
  JetInstance jet = Jet.newJetInstance();
  Pipeline p = buildPipeline();
  System.out.println("Generating model...");
  try {
    jet.newJob(p).join();
    printTransitionsAndMarkovChain(jet);
  } finally {
    Jet.shutdownAll();
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

private void go() throws Exception {
  Job job = null;
  try {
    setup();
    job = jet.newJob(buildPipeline());
    scheduledExecutorService.schedule(job::cancel, 10, SECONDS);
    job.join();
  } catch (CancellationException e) {
    waitForComplete(job);
  } finally {
    cleanup();
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

private void go() throws Exception {
  Job job = null;
  try {
    setup();
    job = jet.newJob(buildPipeline());
    scheduledExecutorService.schedule(job::cancel, 10, SECONDS);
    job.join();
  } catch (CancellationException e) {
    waitForComplete(job);
  } finally {
    cleanup();
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

private void go() {
  try {
    setup();
    jet.newJob(buildPipeline()).join();
  } finally {
    Jet.shutdownAll();
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

private void go() {
  try {
    setup();
    jet.newJob(buildPipeline()).join();
    IMapJet<String, User> map = jet.getMap(AvroSink.MAP_NAME);
    System.out.println("Map Size: " + map.size());
    map.forEach((key, value) -> System.out.println(key + " - " + value));
  } finally {
    Jet.shutdownAll();
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet-demos

public static void main(String[] args) {
  System.out.println("DISCLAIMER: This is not an investment advice");
  DAG dag = buildDag();
  // Start Jet
  JetInstance jet = Jet.newJetInstance();
  startConsolePrinterThread(jet);
  try {
    // Perform the computation
    jet.newJob(dag).join();
  } finally {
    stopConsolePrinterThread();
    Jet.shutdownAll();
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

private void go() {
  prepareSampleData();
  try {
    jet.newJob(coGroupDirect()).join();
    validateCoGroupResults();
    jet.getMap(RESULT).clear();
    jet.newJob(coGroupBuild()).join();
    validateCoGroupResults();
  } finally {
    Jet.shutdownAll();
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

private void go() {
  prepareSampleData();
  try {
    jet.newJob(coGroupDirect()).join();
    validateCoGroupResults();
    jet.getMap(RESULT).clear();
    jet.newJob(coGroupBuild()).join();
    validateCoGroupResults();
  } finally {
    Jet.shutdownAll();
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

private void go() throws Exception {
  try {
    setup();
    Pipeline p = buildPipeline(connectionUrl());
    jet.newJob(p).join();
    jet.getMap(MAP_NAME).values().forEach(System.out::println);
  } finally {
    cleanup();
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

public static void main(String[] args) {
    ApplicationContext context = new AnnotationConfigApplicationContext(AppConfig.class);
    JetInstance jet = context.getBean(JetInstance.class);

    Pipeline pipeline = Pipeline.create();
    pipeline.drawFrom(CustomSourceP.customSource())
        .drainTo(Sinks.logger());

    JobConfig jobConfig = new JobConfig()
        .addClass(AnnotationBasedConfigurationSample.class)
        .addClass(CustomSourceP.class);
    jet.newJob(pipeline, jobConfig).join();

    jet.shutdown();
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet-demos

public static void main(String[] args) {
  JetInstance jet = Jet.newJetInstance();
  Pipeline pipeline = buildPipeline();
  addListener(jet.getMap(TAKE_OFF_MAP), a -> System.out.println("New aircraft taking off: " + a));
  addListener(jet.getMap(LANDING_MAP), a -> System.out.println("New aircraft landing " + a));
  try {
    Job job = jet.newJob(pipeline, new JobConfig().setName("FlightTelemetry").setProcessingGuarantee(ProcessingGuarantee.EXACTLY_ONCE));
    job.join();
  } finally {
    Jet.shutdownAll();
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

private void go() throws Exception {
  try {
    createAvroFile();
    JetInstance jet = Jet.newJetInstance();
    JobConf jobConfig = createJobConfig();
    jet.newJob(buildPipeline(jobConfig)).join();
  } finally {
    Jet.shutdownAll();
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

private void go() throws Exception {
  try {
    setup();
    Pipeline p = buildPipeline(connectionUrl());
    jet.newJob(p).join();
    printTable();
  } finally {
    cleanup();
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet-code-samples

@RequestMapping("/submitJob")
public void submitJob() {
  Pipeline pipeline = Pipeline.create();
  pipeline.drawFrom(CustomSourceP.customSource())
      .drainTo(Sinks.logger());
  JobConfig jobConfig = new JobConfig()
      .addClass(SpringBootSample.class)
      .addClass(CustomSourceP.class);
  instance.newJob(pipeline, jobConfig).join();
}

代码示例来源：origin: hazelcast/hazelcast-jet

@Test(timeout = 20000)
public void test() {
  Pipeline p = Pipeline.create();
  p.drawFrom(Sources.batchFromProcessor("source", preferLocalParallelismOne(CustomSourceP::new)))
   .drainTo(Sinks.fromProcessor("sink", preferLocalParallelismOne(CustomSinkP::new)));
  jetInstance.newJob(p).join();
}

内容来源于网络，如有侵权，请联系作者删除！

Job

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com