240 发简信
IP属地:上海
  • 120
    基于 Canal 设计可扩展、高可用 binlog 同步集群

    问题 https://github.com/alibaba/canal[https://github.com/alibaba/canal] binlog 同步组件,canal...

  • 不错,刚上大学的时候还翻不到相关文章🐮

  • [Flink BroadcastStream]Flink实战广播流之BroadcastStream

    广播状态被引入以支持这样的用例:来自一个流的一些数据需要广播到所有下游任务,在那里它被本地存储,并用于处理另一个流上的所有传入元素。 作为广播状态自然适合出现的一个例子,我们...

  • 120
    Flink Join实现

    Window Join 基于窗口的Join是将具有相同key并位于同一个窗口中的事件进行联结。 用法: 官方案例: Tumbling Window Join的实现,关于其他的...

  • Apache Spark 动态分区 OverWrite 问题

    1、问题:spark Dataframe : partition_day.write.partitionBy("day").mode(SaveMode.Overwrite)....