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 appClass, 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 appClass,
                       String[] args)
                throws Exception

数据流启动入口

参数:

appClass - 应用入口类

args - 命令行参数

抛出:

Exception