Flink输出结果和触发程序

一、输出方式

• 基于文件

  // 输出为Text文件
  stream.writeAsText("/path/to/file");
  // 输出为CSV文件
  stream.writeAsCsv("/path/to/file");
  

• 基于Socket

  // 输出到Socket
  stream.writeToSocket(host,port,SerializationSchema)
  

• 基于标准/错误输出

  // 打印数据到控制台
  stream.print();
  // 写入标准输出流(错误信息)
  stream.printToErr();
  

二、触发程序

• 在StreamExecutionEnvironment中，需要调用ExecutionEnvironment的execute()方法来触发应用程序的执行。execute()方法返回JobExecutionResult类型的结果，其中包含程序执行的时间和累加器等指标
• DataStream应用程序需要显性的调用execute()方法来运行程序。如果不调用execute()方法，则DataStream应用程序不会执行。在DataSet应用程序中的算子已经包含对execute()方法的调用，所以不能再次调用execute()方法，否则会出现程序异常