cascading.flow.Flow.isStopJobsOnExit()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(2.3k)|赞(0)|评价(0)|浏览(131)

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

Flow.isStopJobsOnExit介绍

[英]Method isStopJobsOnExit returns the stopJobsOnExit of this Flow object. Defaults to true.
[中]方法isStopJobsOnExit返回此流对象的stopJobsOnExit。默认为true。

代码示例

代码示例来源:origin: cwensel/cascading

private boolean isStopJobsOnExit()
 {
 if( getFlows().isEmpty() )
  return false; // don't bother registering hook
 return getFlows().get( 0 ).isStopJobsOnExit();
 }

代码示例来源:origin: cascading/cascading-hadoop2-tez

private static synchronized void registerHadoopShutdownHook( Flow flow )
 {
 if( !flow.isStopJobsOnExit() )
  return;
 // guaranteed singleton here
 if( shutdownHook != null )
  return;
 getHdfsShutdownHook();
 shutdownHook = new ShutdownUtil.Hook()
  {
  @Override
  public Priority priority()
   {
   return Priority.LAST; // very last thing to happen
   }
  @Override
  public void execute()
   {
   callHdfsShutdownHook();
   }
  };
 ShutdownUtil.addHook( shutdownHook );
 }

代码示例来源:origin: cwensel/cascading

private static synchronized void registerHadoopShutdownHook( Flow flow )
 {
 if( !flow.isStopJobsOnExit() )
  return;
 // guaranteed singleton here
 if( shutdownHook != null )
  return;
 getHdfsShutdownHook();
 shutdownHook = new ShutdownUtil.Hook()
  {
  @Override
  public Priority priority()
   {
   return Priority.LAST; // very last thing to happen
   }
  @Override
  public void execute()
   {
   callHdfsShutdownHook();
   }
  };
 ShutdownUtil.addHook( shutdownHook );
 }

代码示例来源:origin: cwensel/cascading

private static synchronized void registerHadoopShutdownHook( Flow flow )
 {
 if( !flow.isStopJobsOnExit() )
  return;
 // guaranteed singleton here
 if( shutdownHook != null )
  return;
 getHdfsShutdownHook();
 shutdownHook = new ShutdownUtil.Hook()
  {
  @Override
  public Priority priority()
   {
   return Priority.LAST; // very last thing to happen
   }
  @Override
  public void execute()
   {
   callHdfsShutdownHook();
   }
  };
 ShutdownUtil.addHook( shutdownHook );
 }

代码示例来源:origin: cascading/cascading-hadoop2-mr1

private static synchronized void registerHadoopShutdownHook( Flow flow )
 {
 if( !flow.isStopJobsOnExit() )
  return;
 // guaranteed singleton here
 if( shutdownHook != null )
  return;
 getHdfsShutdownHook();
 shutdownHook = new ShutdownUtil.Hook()
  {
  @Override
  public Priority priority()
   {
   return Priority.LAST; // very last thing to happen
   }
  @Override
  public void execute()
   {
   callHdfsShutdownHook();
   }
  };
 ShutdownUtil.addHook( shutdownHook );
 }

相关文章