Clone of flume-ng for experimental work.
APACHE-2.0 License
基于flink的实时流计算web平台
Some extensions to Flume to help with collecting logs and storing as Avro.
A data integration framework
Demo applications and code examples for Apache Kafka's Streams API.
基于Flink实现的商品实时推荐系统。flink统计商品热度,放入redis缓存,分析日志信息,将画像标签和实时记录放入Hbase。在用户发起推荐请求后,根据用户画像重排序热度榜,并结合协同过滤...
A realtime data streaming application to access, aggregate and format events
Apache InLong - a one-stop, full-scenario integration framework for massive data
flume-ng kafka sink
Apache Flume is a distributed, reliable, and available service for efficiently collecting, aggreg...
基于开源的flink,对其实时sql进行扩展;主要实现了流与维表的join,支持原生flink SQL所有的语法
A high performance, reliable pixel server
Apache Flink
Apache Flink shaded artifacts repository