sparkjobflow:这是一个将Spark作业调制为流方式的项目，它还处理模块依赖性并支持并行作业运行。 甚至可以用于一般用...

sparkjobflow 这是一个将Spark作业调制为流方式的项目，它还处理模块依赖性并支持并行作业运行。 甚至可以用于一般目的。 用法： object Myclass extends App { val controller = new Controller controller .register( Module1 ) .register( new Module2 ) controller.start() } @ failFast object Module1 extends IModule { override def moduleName = " M1 " override def depend = None override def process ( in : Seq [ Any ]) = { " M1