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

Flow.addStepListener介绍

[英]Method addStepListener registers the given flowStepListener with this instance.
[中]方法addStepListener将给定的flowStepListener注册到此实例。

代码示例

代码示例来源：origin: LiveRamp/cascading_ext

@Override
public void complete(JobPersister persister, boolean failOnCounterFetch) {
 AtomicBoolean isComplete = new AtomicBoolean(false);
 flow.addListener(new StopListener(isComplete));
 flow.addStepListener(new JobRecordListener(
   persister,
   failOnCounterFetch
 ));
 flow.complete();
 //  TODO kill skipCompleteListener once we figure out the cascading internal NPE (upgrade past 2.5.1 maybe?)
 if (!isComplete.get() && !skipCompleteListener) {
  throw new RuntimeException("Flow terminated but did not complete!  Possible shutdown hook invocation.");
 }
}

代码示例来源：origin: LiveRamp/hank

flow.addStepListener(listener);