lilijiangnan Goto Github PK

antlr4

ANTLR (ANother Tool for Language Recognition) is a powerful parser generator for reading, processing, executing, or translating structured text or binary files.

bigdata

bigdata intro

csdn-esper

Esper专栏源代码

element-angular

Element for Angular

flink-learning

flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

flowmix

Flowmix is a flexible event processing engine for Apache Storm. It supports complex correlations of events via sliding/tumbling windows. It allows parallel streams to be processed that can be grouped together in different ways.

grammars-v4

Grammars written for ANTLR v4; expectation that the grammars are free of actions.

recommendsys

推荐项目（实时推荐和离线推荐）

sharding-jdbc

A JDBC driver for shard databases and tables

sharding-sphere-doc

Sharding-Sphere website & documents

sharding-sphere-example

Sharding-Sphere examples

shield

基于Strom的日志实时流量分析主动防御(CCFirewall)系统

squall

A streaming / online query processing / analytics engine based on Apache Storm

storm

Mirror of Apache Storm

storm-documents

Apache Storm 官方文档翻译

storm-esper

Storm - Esper integration experiment

storm-trident

《Storm Blueprints: Patterns for Distributed Real-time Computation 》一书的源码和翻译

streamcql

syncspout

SyncSpout是上海华瑞银行（SHRB）大数据团队开发的，用来构造可交互的、同步的Storm拓扑的组件。我们在做实时推荐系统中，希望将Storm的并发性和分布式计算能力应用到“请求-响应”范式中， 比如客户的某次购买行为能够以消息的形式发送到storm拓扑中，storm在指定时间返回推荐结果，也就是说storm需要具有可交互性。基于这样的背景，大数据团队开发了SyncSpout组件， 该组件可以接收客户端异步的消息，经过Storm拓扑异步计算，在指定时间内返回给客户端。