Flink Atlas Agent
基于开源的flink,对其实时sql进行扩展;主要实现了流与维表的join,支持原生flink SQL所有的语法
基于Flink实现的商品实时推荐系统。flink统计商品热度,放入redis缓存,分析日志信息,将画像标签和实时记录放入Hbase。在用户发起推荐请求后,根据用户画像重排序热度榜,并结合协同过滤...
Clone of flume-ng for experimental work.
Read Cypher query results into Apache Flink and write datasets to Neo4j using Cypher batches.
A data integration framework
A kubernetes CRD and controller to manage Flink jobs running on your any Flink Job Manager
flume-ng kafka sink
Apache Flume is a distributed, reliable, and available service for efficiently collecting, aggreg...
Apache Flink
Flink connector provides a source and a sink that can read from and write to Neo4J graph database
Tools for helping integrate OSM data in hdfs using csv or avro files, using flink (implements PBF...
A realtime data streaming application to access, aggregate and format events
Apache Flink shaded artifacts repository
基于flink的实时流计算web平台