用 Flink 获得数据并输出

首先，你需要创建一个 Flink 的 StreamExecutionEnvironment 对象。然后，使用该对象创建一个 DataStream 对象，这个 DataStream 对象是从一个数据源获取数据的。最后，使用 Flink 的 DataStream API 中的方法将数据输出到指定的目的地。

下面是一个简单的例子，展示如何使用 Flink 从一个文件中读取数据，对数据进行处理并将结果输出到控制台。

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class FlinkExample {

    public static void main(String[] args) throws Exception {
        
        // 创建 Flink 的 StreamExecutionEnvironment 对象
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        // 从文本文件创建 DataStream 对象
        DataStream<String> text = env.readTextFile("path/to/file.txt");

        // 处理数据
        DataStream<String> processed = text.map(line -> line.toUpperCase());

        // 将结果输出到控制台
        processed.print();

        // 启动程序
        env.execute("Flink Example");
    }

}

在上面的例子中，我们首先使用 `StreamExecutionEnvironment.getExecutionEnvironment()` 方法创建了一个 Flink 的 StreamExecutionEnvironment 对象。接着，我们使用 `env.readTextFile("path/to/file.txt")` 方法从文本文件中读取数据，并创建了一个 DataStream 对象。然后，我们使用 DataStream API 中的 `map()` 方法对数据进行处理，将每一行的数据转换为大写字母。最后，我们使用 `processed.print()` 方法将处理后的结果输出到控制台。

最后，我们调用 `env.execute("Flink Example")` 方法启动程序。注意，`env.execute()` 方法是一个阻塞方法，程序会一直运行直到它被停止。