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")
  }
}

1. 在项目根目录下执行mvn package
2. 提交任务
   1.通过命令提交

   ./bin/flink run jarName.jar
   

   2.通过ui提交，并填写入口class，提交任务
   http://localhost:8081/#/overview
   

这篇好文章是转载于：学新通技术网