flink-helloword

安装启动flink 后我们跑一个demo。

demo如下：

package org.myorg.quickstart

import org.apache.flink.streaming.api.scala._

object HelloWorld {
  def main(args: Array[String]): Unit = {

    val env = StreamExecutionEnvironment.getExecutionEnvironment
    val text = env.fromElements("1212w")
    val counts = text.map {
      _.toLowerCase
    }

    counts.print()

    env.execute("HelloWord")
  }
}

在项目根目录下执行mvn package提交任务，并填写入口class，提交任务