com.zto.fire.flink.task

类 FlinkSchedulerManager

java.lang.Object

com.zto.fire.core.task.SchedulerManager

com.zto.fire.flink.task.FlinkSchedulerManager

所有已实现的接口:

Serializable

public class FlinkSchedulerManager
extends SchedulerManager

Flink 定时调度任务管理器

从以下版本开始:

1.0.0

作者:

ChengLong

另请参阅:

序列化表格

字段概要

从类继承的字段 com.zto.fire.core.task.SchedulerManager

DRIVER, EXECUTOR

方法概要

限定符和类型	方法和说明
static SchedulerManager	getInstance() 获取单例实例
protected String	label()

从类继承的方法 com.zto.fire.core.task.SchedulerManager

addScanTask, buildSchedulerInfo, execute, init, registerTasks, schedulerIsStarted, shutdown

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

方法详细资料

getInstance

public static SchedulerManager getInstance()

获取单例实例

label

protected String label()

指定者:

label 在类中 SchedulerManager