def main()

in src/main/scala/com/aliyun/emr/example/flink/FlinkOSSSample.scala [26:47]

• 13 lines of code
• 2 McCabe index (conditional complexity)

  def main(args: Array[String]) {

    val params: ParameterTool = ParameterTool.fromArgs(args)

    // set up execution environment
    val env = ExecutionEnvironment.getExecutionEnvironment

    // make parameters available in the web interface
    env.getConfig.setGlobalJobParameters(params)

    if (!params.has("input")) {
      println("Executing WordCount example with default input data set.")
      println("Use --input to specify file input.")
      sys.exit(1)
    }
    val text = env.readTextFile(params.get("input"))

    val top10 = text.first(10)

    top10.collect().foreach(println)

  }