자바 프레임워크와 빅데이터 분석의 최고의 조합

import org.apache.spark.sql.SparkSession;

public class SparkExample {

    public static void main(String[] args) {
        SparkSession spark = SparkSession.builder().appName("SparkExample").getOrCreate();

        // 读取 CSV 数据文件
        DataFrame df = spark.read().csv("data.csv");

        // 执行分析操作
        df.groupBy("column_name").count().show();

        // 写入结果到文件
        df.write().csv("output.csv");
    }
}

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataOutputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;

public class HadoopExample {

    public static void main(String[] args) {
        Configuration conf = new Configuration();
        FileSystem fs = FileSystem.get(conf);

        Path path = new Path("hdfs://path/to/data.csv");
        FSDataOutputStream out = fs.create(path);

        // 写入数据到文件
        out.write("data to be stored".getBytes());
        out.close();
    }
}

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

public class FlinkExample {

    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        // 创建源，产生实时数据流
        DataStream<String> inputStream = env.fromElements("data1", "data2", "data3");

        // 执行流处理操作
        inputStream.flatMap((FlatMapFunction<String, String>) (s, collector) -> collector.collect(s))
                .print();

        env.execute();
    }
}