dingqizhou Goto Github PK

azkaban

Azkaban workflow manager.

canal

阿里巴巴mysql数据库binlog的增量订阅&消费组件 。阿里云DRDS( https://www.aliyun.com/product/drds )、阿里巴巴TDDL 二级索引、小表复制powerd by canal.

datax

DataX 是阿里巴巴集团内被广泛使用的离线数据同步工具/平台，实现包括 MySQL、Oracle、HDFS、Hive、OceanBase、HBase、OTS、ODPS 等各种异构数据源之间高效的数据同步功能。

dbus

dubbo

Dubbo is a high-performance, java based, open source RPC framework

flink

Apache Flink

flink-connector-redis_2.11

forked from org.apache.bahir:flink-connector-redis_2.11:1.0

flinksql

基于Flink的产品化，类似阿里Blink，使用SQL开发Flink任务。 Flink master 1.8和1.9改动比较大，等发布后开发v3版本。有兴趣的同学可以帮助完善

flinkstreamsql

基于开源的flink，对其实时sql进行扩展；主要实现了流与维表的join，支持原生flink SQL所有的语法

flume

Mirror of Apache Flume

flume-ng-rabbitmq

Flume plugin for RabbitMQ

flume-source-taildir-recursive

Flume1.7.0 TaildirSource support monitor sub-directories recursivly

go-mysql-elasticsearch

Sync MySQL data into elasticsearch

incubator-superset

Apache Superset (incubating) is a modern, enterprise-ready business intelligence web application

kafka-manager

A tool for managing Apache Kafka.

mysql-parser

mysql-tracker

mysql binlog transportation

nvidia-container-runtime

NVIDIA container runtime

pm

real-time-stream-processing-engine

This is an example of real time stream processing using Spark Streaming, Kafka & Elasticsearch.

riskcontrol

sparkjava_storm_websocket

Example creating an endpoint with Sparkjava, produced to RabbitMQ, consumed and processed by Apache Storm and published using Apache Camel to Websocket

storm

Distributed and fault-tolerant realtime computation: stream processing, continuous computation, distributed RPC, and more

super_demos

Hadoop Spark Kafak RabbitMQ Demos

zeus

Hadoop作业平台