Backlinking plays a vital role in SEO st...
...
还有 8 人发表了评论 加入3226人围观scala
Flink基础学习(Scala):数据输出Sink（flink scala）
天上的小小 发表于2024-06-27 浏览6668 评论0
一、前言
前面我们已经学习了Flink的读取及转换，这篇文章将讲讲如何将转换后的数据输出，也就是数据落地，落地后给第三方进行使用
二、数据输出
数据落地多种方式，我们将从以下几个方面来说明
2.1 输出到文件
import org.apache.flink.api.common.serialization.SimpleStringEncoder
import org.apache.flink.core.fs.Path
import org.apache.flink.str
scala
Flink / Scala - 7.DataSet & DataStream Sink 输出数据详解
愿林 发表于2024-06-21 浏览6935 评论0
一.引言
Flink 的数据处理主要分三步，第一步 Source 为数据源，分为 DataSet 和 DataStreaming ，后一步为 Transformation 负责处理和转换数据，针对不同的 DataSource，Transformation 可能会存在差异，最后一步是 sink 负责将结果输出。前面介绍了 DataSet 的 Source 和 Transformation，这里介绍下 DataSet 和 DataStreaming 的 Sink 相关 API。
Tips: