Pulsar SparkWhen Apache Pulsar meets Apache Spark
Stars: ✭ 55 (-34.52%)
Pulsar FlinkElastic data processing with Apache Pulsar and Apache Flink
Stars: ✭ 126 (+50%)
Flink Learningflink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例,还有 Flink 落地应用的大型项目案例(PVUV、日志存储、百亿数据实时去重、监控告警)分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》
Stars: ✭ 11,378 (+13445.24%)
Flink Sql CookbookThe Apache Flink SQL Cookbook is a curated collection of examples, patterns, and use cases of Apache Flink SQL. Many of the recipes are completely self-contained and can be run in Ververica Platform as is.
Stars: ✭ 189 (+125%)
TiBigDataTiDB connectors for Flink/Hive/Presto
Stars: ✭ 192 (+128.57%)
Websockets-Vertx-Flink-KafkaA simple request response cycle using Websockets, Eclipse Vert-x server, Apache Kafka, Apache Flink.
Stars: ✭ 14 (-83.33%)
football-eventsEvent-Driven microservices with Kafka Streams
Stars: ✭ 57 (-32.14%)
Elkeid-HUBElkeid HUB is a rule/event processing engine maintained by the Elkeid Team that supports streaming/offline (not yet supported by the community edition) data processing. The original intention is to solve complex data/event processing and external system linkage requirements through standardized rules.
Stars: ✭ 62 (-26.19%)
dockerfilesMulti docker container images for main Big Data Tools. (Hadoop, Spark, Kafka, HBase, Cassandra, Zookeeper, Zeppelin, Drill, Flink, Hive, Hue, Mesos, ... )
Stars: ✭ 29 (-65.48%)
streamsx.kafkaRepository for integration with Apache Kafka
Stars: ✭ 13 (-84.52%)
spStream Processors on Kafka in Golang
Stars: ✭ 29 (-65.48%)
kafka-workersKafka Workers is a client library which unifies records consuming from Kafka and processing them by user-defined WorkerTasks.
Stars: ✭ 30 (-64.29%)
flink-clientJava library for managing Apache Flink via the Monitoring REST API
Stars: ✭ 48 (-42.86%)
product-spAn open source, cloud-native streaming data integration and analytics product optimized for agile digital businesses
Stars: ✭ 80 (-4.76%)
Perfect-KafkaAn Express Swift Client of Apache Kafka 0.8, the Stream Processing Platform
Stars: ✭ 20 (-76.19%)
fdp-modelserverAn umbrella project for multiple implementations of model serving
Stars: ✭ 47 (-44.05%)
Lidea大型分布式系统实时监控平台
Stars: ✭ 28 (-66.67%)
logparserEasy parsing of Apache HTTPD and NGINX access logs with Java, Hadoop, Hive, Pig, Flink, Beam, Storm, Drill, ...
Stars: ✭ 139 (+65.48%)
PsiPlatform for Situated Intelligence
Stars: ✭ 249 (+196.43%)
daggerDagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming data.
Stars: ✭ 238 (+183.33%)
mediapipe plusThe purpose of this project is to apply mediapipe to more AI chips.
Stars: ✭ 38 (-54.76%)
openPDCOpen Source Phasor Data Concentrator
Stars: ✭ 109 (+29.76%)
csvpluscsvplus extends the standard Go encoding/csv package with fluent interface, lazy stream operations, indices and joins.
Stars: ✭ 67 (-20.24%)
dpkb大数据相关内容汇总,包括分布式存储引擎、分布式计算引擎、数仓建设等。关键词:Hadoop、HBase、ES、Kudu、Hive、Presto、Spark、Flink、Kylin、ClickHouse
Stars: ✭ 123 (+46.43%)
makinageStream Processing Made Easy
Stars: ✭ 31 (-63.1%)
beepbeep-3An event stream processor anyone can use
Stars: ✭ 20 (-76.19%)
flink-learnLearning Flink : Flink CEP,Flink Core,Flink SQL
Stars: ✭ 70 (-16.67%)
mxfactoriala payment application intended for deployment by the united states treasury
Stars: ✭ 36 (-57.14%)
flink-deployerA tool that help automate deployment to an Apache Flink cluster
Stars: ✭ 143 (+70.24%)
blockchain-etl-streamingStreaming Ethereum and Bitcoin blockchain data to Google Pub/Sub or Postgres in Kubernetes
Stars: ✭ 57 (-32.14%)
AmadeusHarmonious distributed data analysis in Rust.
Stars: ✭ 240 (+185.71%)
ramenA stream processing language and compiler for small-scale monitoring
Stars: ✭ 14 (-83.33%)
ReDeA Redis dehydrator module
Stars: ✭ 63 (-25%)
xlstreamTurns XLSX into a readable stream.
Stars: ✭ 148 (+76.19%)
go-riversCollection of stream processing / multiplexing / networking libs in Go
Stars: ✭ 35 (-58.33%)
frizzleThe magic message bus
Stars: ✭ 14 (-83.33%)
dlinkDinky is an out of the box one-stop real-time computing platform dedicated to the construction and practice of Unified Streaming & Batch and Unified Data Lake & Data Warehouse. Based on Apache Flink, Dinky provides the ability to connect many big data frameworks including OLAP and Data Lake.
Stars: ✭ 1,535 (+1727.38%)
DparkPython clone of Spark, a MapReduce alike framework in Python
Stars: ✭ 2,668 (+3076.19%)
hadoopofficeHadoopOffice - Analyze Office documents using the Hadoop ecosystem (Spark/Flink/Hive)
Stars: ✭ 56 (-33.33%)
WatermillBuilding event-driven applications the easy way in Go.
Stars: ✭ 3,504 (+4071.43%)
flink-connector-kudu基于Apache-bahir-kudu-connector的flink-connector-kudu,支持Flink1.11.x DynamicTableSource/Sink,支持Range分区等
Stars: ✭ 40 (-52.38%)
Fluent BitFast and Lightweight Logs and Metrics processor for Linux, BSD, OSX and Windows
Stars: ✭ 3,223 (+3736.9%)
CoreBuild platforms that flexibly mix SQL, batch, and stream processing paradigms
Stars: ✭ 231 (+175%)
gretel-python-clientThe Gretel Python Client allows you to interact with the Gretel REST API.
Stars: ✭ 28 (-66.67%)
distogramA library to compute histograms on distributed environments, on streaming data
Stars: ✭ 19 (-77.38%)
PipelinedbHigh-performance time-series aggregation for PostgreSQL
Stars: ✭ 2,447 (+2813.1%)
Incubator StreampipesApache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
Stars: ✭ 209 (+148.81%)
SANSA-StackBig Data RDF Processing and Analytics Stack built on Apache Spark and Apache Jena http://sansa-stack.github.io/SANSA-Stack/
Stars: ✭ 130 (+54.76%)