SuCicada - 蘇曉蝉
  文章分類
datelog 1 Flink 1 Java 1 dict 32 log 2 lyrics 17 mind 3 CS 24 TODO 3 TOOL 1 dream 1 Akka 2 Flink 4 Git 1 Hadoop 2 Hbase 1 Hudi 2 JVM 1 Scala 1 network 4 设计模式 2 SQL 1
README README
flinkSQL 追加模式（toAppendStream）与缩进模式（toRetractStream）的区别https://blog.csdn.net/young_0609/article/details/109466857 Apache
2024-05-27 dict CS Flink SQL
流程 流程
假设.map(new RichMapFunction(){…}) RichMapFunction首先会在client实例化一次.然后flink会将map对象序列化分发出去. ClosureCleaner 检查函数闭包可序列化 https:/
2024-05-27 dict CS Flink
StreamingFileSink StreamingFileSink
snapshotState 和 notifyCheckpointComplete 时机 先snapshotState, 为了关闭文件. 文件在关闭之前都是空的. private InProgressFileWriter.PendingFi
2024-05-27 dict CS Flink
Flink 风水哲学 Flink 风水哲学
flink一般会用在哪里: 实时etl, 实时数仓, 实时报告分析, 监控, 推荐 我们将这些场景抽象出来，能看到我们的flink在里面做了一个什么作用: 是的, 很简单: 读取一个或多个输入源的数据, 然后经过一系列运算, 讲结果输
2024-05-27 dict CS Flink