实时计算 创建

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

public class RealTimeProcessingExample {
    public static void main(String[] args) throws Exception {
        // 创建流处理环境
        final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        // 假设我们从一个数据源接收数据流
        DataStream<String> dataStream = env.socketTextStream("localhost", 9999);

        // 对数据流进行处理
        DataStream<Integer> counts = dataStream
            .flatMap((String value, Collector<String> out) -> {
                for (String word : value.toLowerCase().split("\\W+")) {
                    out.collect(word);
                }
            })
            .keyBy(0)
            .sum(1);

        // 输出结果
        counts.print();

        // 执行程序
        env.execute("Real-time Data Processing Example");
    }
}