Flink Learning 10: Use idea to write WordCount and package and run

1. Write a program

5 steps

import org.apache.flink.api.scala._object flinkTest {def main(args: Array[String]): Unit = {//first: build envval env = ExecutionEnvironment.getExecutionEnvironment//second: create datasourceval text: DataSet[String] = env.fromElements("hello,dog","hell0,cat","hello,dog")//third: transferval counts = text.flatMap(_.toLowerCase.split(",")).map((_, 1)).groupBy(0).sum(1)//Fourth: printcounts.print()}}}}

Output result:

2. Compile and package

Click maven on the right, then double-click the package, you can

After the introduction, you can see the jar package in the target on the left

3. Submit the cluster for execution

--class specifies the name of the class, space specifies the name of the jar package