FLink怎么打印输出到stdout
时间: 2024-03-23 14:39:52 浏览: 246
在 Flink 中,您可以使用 `print()` 函数将数据流中的数据打印输出到 stdout。
以下是一个简单的示例:
```java
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
public class PrintToStdoutExample {
public static void main(String[] args) throws Exception {
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
// 创建一个包含整数的数据流
final DataStream<Integer> dataStream = env.fromElements(1, 2, 3, 4, 5);
// 打印数据流中的数据到 stdout
dataStream.print();
// 执行 Flink 作业
env.execute("Print to Stdout Example");
}
}
```
在这个示例中,我们创建了一个包含整数的数据流并使用 `print()` 函数将数据流中的数据打印输出到 stdout。当执行 Flink 作业时,这些数据将被打印到控制台。
阅读全文