Song's Ravine, You don't travel to see different things, you travel to see things differently.

  • Blog
  • About
  • RSS
  • Search
  • 装修 (2)
  • NAS (2)
  • Tool (1)
  • 分布式 (2)
  • Spring (2)
  • Web (1)
  • Thinking (1)
  • Algorithm (1)
  • 区块链 (1)
  • Website (1)
  • SpringMVC (1)
  • SpringBoot (1)
  • App (5)
  • SelfMade (2)
  • Flink (1)
  • Netty (1)
  • Problem (1)
  • Kafka (4)
  • Kubernetes (1)
  • Java (1)
  • Windows (2)
  • Linux (2)

Flink Window机制与Timer

Dec 14, 2019

最近有一个实际的场景需求,需要实时统计总数,于是想到了flink,从入门到实战,整个过程中一直不断的思考实际业务中的问题,在flink中如何解决,与kafka-stream的对比和spark的对比等等。 整个思考和写出demo的过程中,对window机制有了深入的了解,并通过阅读flink java client的源码,了解了其trigger的实现。 本文从实际需求出发,通过提出问题解决问题,结合源码了解flink。


© Song 2015 - 2023