240 发简信
IP属地:广东
  • Reactor之发射器(Flux、Mono)转换操作函数

    Reactor 发射器转换操作函数 concatWithValues 将值连接到Flux的末尾。 concat 连接两个Flux, 连接由源下游发射的迭代转发元素提供的所有源...

  • Flink状态存储

    Flink提供了不同的状态存储方式,并说明了状态如何存和存储在哪里。状态可以被存储在Jvm的堆和堆外。根据状态存储方式的不同,Flink也能代替应用管理状态,意思是Flink...

  • 120
    Flink Exactly-Once 投递实现浅析

    随着近来越来越多的业务迁移到 Flink 上,对 Flink 作业的准确性要求也随之进一步提高,其中最为关键的是如何在不同业务场景下保证 exactly-once 的投递语义...

  • RichSinkFunction 的open方法多任务状况下会被调用一次还是多次? 多并行度情况下会被调用多次还是一次?

    flink 源码分析1之RichSinkFunction

    flink sink 2 mysql demo 我们先看一个自定义sink 的demo,将 nc 的数据写入到mysql 中。 RichSinkFunction 的类结构 可...