Flink输出算子

阅读 24

2024-11-13

一,Flink程序通用结构

二,使用输出算子输出结果到文件

需要在项目的根目录下创建目录output

package com.xxx.demo;

import org.apache.flink.api.common.serialization.SimpleStringEncoder;
import org.apache.flink.configuration.MemorySize;
import org.apache.flink.connector.file.sink.FileSink;
import org.apache.flink.core.fs.Path;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.funct

精彩评论(0)

0 0 举报