程序包 xin.manong.stream.framework.runner

类 StreamRunner

java.lang.Object

xin.manong.stream.framework.runner.StreamRunner

public class StreamRunner
extends Object

数据流运行器

作者:

frankcl

构造器概要

构造器

构造器	说明
StreamRunner(StreamRunnerConfig config)

方法概要

修饰符和类型	方法	说明
static void	run(Class resourceClass, String[] args)	数据流启动入口
boolean	start()	启动调度器
void	stop()	停止调度器

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

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

构造器详细资料

StreamRunner

public StreamRunner(StreamRunnerConfig config)

方法详细资料

start

public boolean start()
              throws Exception

启动调度器

返回:

成功返回true，否则返回false

抛出:

Exception

stop

public void stop()

停止调度器

run

public static void run(Class resourceClass,
                       String[] args)
                throws Exception

数据流启动入口

参数:

resourceClass - 资源配置类

args - 命令行参数

抛出:

Exception