flink写入minio的示例代码

以下是使用 flink-s3-fs-hadoop 插件将 Flink 流式数据写入 MinIO 存储桶的示例代码：

import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink;
import org.apache.flink.streaming.connectors.fs.bucketing.DateTimeBucketer;
import org.apache.flink.streaming.connectors.fs.StringWriter;
import org.apache.flink.streaming.connectors.fs.SequenceFileWriter;
import org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink;
import org.apache.flink.streaming.connectors.fs.bucketing.DateTimeBucketer;

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

        // 创建一个DataStream，假设它包含字符串
        DataStream<String> stream = env.fromElements("Hello", "World", "Flink");

        // 创建一个BucketingSink，将流式数据写入MinIO存储桶中
        BucketingSink<String> sink = new BucketingSink<>("s3a://my-bucket-name/path/to/files");
        sink.setBucketer(new DateTimeBucketer<>("yyyy-MM-dd--HHmm"));
        sink.setWriter(new StringWriter<>());

        // 将DataStream写入BucketingSink
        stream.addSink(sink);

        // 执行Flink作业
        env.execute("WriteToMinIO");
    }
}

在上面的示例中，我们使用 `BucketingSink` 将 Flink 流式数据写入 MinIO 存储桶。我们设置了 `DateTimeBucketer` 作为文件桶，并使用 `StringWriter` 将数据写入文本文件。最后，我们将 `DataStream` 写入 `BucketingSink` 并执行 Flink 作业。请注意，我们在 s3a URL 中指定了 MinIO 存储桶的名称和路径。