方法:html
object BatchJob {}apache
object StreamingJob {}编程
import org.apache.flink.api.scala._ /** --译文 * Flink批处理做业的骨架。 * *有关如何编写Flink批处理应用程序的教程,请查看 *有关<a href="http://flink.apache.org/docs/stable/"> Flink网站</a>的教程和示例。 * *将您的appliation打包成JAR文件以供执行, *将POM.xml文件中的主类更改成此类(只需搜索'mainClass') *并在命令行上运行'mvn clean package'。 */ object BatchJob { def main(args: Array[String]) { // set up the batch execution environment val env = ExecutionEnvironment.getExecutionEnvironment /* 译文: / * *在这里,您能够开始为Flink建立执行计划。 * *从获取环境中的一些数据开始,好比 * env.readTextFile(textPath); * *而后,使用操做转换生成的DataSet [String] * 喜欢 * .filter() * .flatMap() * .join() * .group() * * 还有不少。 *看一下编程指南: * * http://flink.apache.org/docs/latest/apis/batch/index.html * *和例子 * * http://flink.apache.org/docs/latest/apis/batch/examples.html * * / //执行程序 * */ env.execute("Flink Batch Scala API Skeleton") } }