本文整理了Java中cascading.flow.Flow.isStopJobsOnExit()
方法的一些代码示例,展示了Flow.isStopJobsOnExit()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Flow.isStopJobsOnExit()
方法的具体详情如下:
包路径:cascading.flow.Flow
类名称: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 );
}
内容来源于网络,如有侵权,请联系作者删除!