一、 实验内容 基于Apache Flink 的StreamExecutionEnvironment，使用Java语言，实现批流融合的词频统计。其中数据源分别来自文件（批处理）和socket（流处理），将这两种数据源合并后再进行词频统计，单词不区分大小写。 用idea编写程序，写出完整代码

请注意，由于我是一个语言模型AI，我无法直接提供您IDEA编写的完整代码。但是，我可以提供一些基于Apache Flink 的StreamExecutionEnvironment和Java语言的代码示例，供您参考和学习。

首先，您需要添加Flink和相关库的依赖。例如：

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-java</artifactId>
    <version>1.12.2</version>
</dependency>
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-streaming-java_2.11</artifactId>
    <version>1.12.2</version>
</dependency>

然后，我们可以开始编写代码。以下是一个可能的实现：

import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.utils.ParameterTool;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.source.SourceFunction;
import org.apache.flink.util.Collector;

public class BatchStreamWordCount {

    public static void main(String[] args) throws Exception {
        // 设置参数
        final ParameterTool params = ParameterTool.fromArgs(args);
        final String input = params.get("input", "batch_input.txt");
        final int port = params.getInt("port", 9000);

        // 批处理环境
        final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
        // 从文件读取数据
        DataStream<String> batchDataStream = env.readTextFile(input)
                .flatMap(new FlatMapFunction<String, String>() {
                    @Override
                    public void flatMap(String line, Collector<String> out) {
                        for (String word : line.split("\\s")) {
                            out.collect(word.toLowerCase());
                        }
                    }
                })
                .keyBy(word -> word)
                .sum(1);

        // 流处理环境
        final StreamExecutionEnvironment streamEnv = StreamExecutionEnvironment.getExecutionEnvironment();
        // 从socket读取数据
        DataStream<String> streamDataStream = streamEnv.socketTextStream("localhost", port)
                .flatMap(new FlatMapFunction<String, String>() {
                    @Override
                    public void flatMap(String line, Collector<String> out) {
                        for (String word : line.split("\\s")) {
                            out.collect(word.toLowerCase());
                        }
                    }
                })
                .keyBy(word -> word)
                .sum(1);

        // 合并批处理和流处理的数据
        DataStream<String> mergedDataStream = batchDataStream.union(streamDataStream);

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

        // 执行任务
        streamEnv.execute("BatchStreamWordCount");
    }
}

此代码包括两个部分：批处理和流处理。在批处理中，我们从文件中读取数据，进行单词切分和计数。在流处理中，我们从socket中读取数据，进行单词切分和计数。然后，我们将两个数据流合并，并输出结果。

请注意，此代码仅供参考，您需要根据自己的实际需求进行修改和优化。