Pinned Repositories
aiot-rust
阿里云物联网设备端 Rust SDK / Alink 协议
awesome-flink
😎 A curated list of amazingly awesome Flink and Flink ecosystem resources
cockburst
一个高性能,可靠,异步的本地持久化队列实现;重启JVM、重启服务器、或者强制KILL进程时,队列里的数据不丢失;
elasticSearch-client
elsaticSearch-client主要是针对elastcSearch提供的rest api做封装,不依赖elasticSearch提供的jar包。是用scala语言封装的一个工具包
flink
Apache Flink
flink-demo
针对flink初学者,改造自flink官方提供的demo。后续我会将我学习flink过程中写的一些示例代码加入进来
key-value-store
Generic key-value store/cache
lightling
lightling是基于spark-streaming和flink封装的一个实时计算平台。目前只是针对spark-streaming,后续会加入对flink的支持。
Quicksql
Simpler, Safer, Faster Unified SQL Analytics Engine for Multi-Datasources
slides
将flink以及spark相关知识梳理成文档。内容来源于网络。也有自己的理解。我只是大自然的搬运工
dakongyi2014's Repositories
dakongyi2014/slides
将flink以及spark相关知识梳理成文档。内容来源于网络。也有自己的理解。我只是大自然的搬运工
dakongyi2014/elasticSearch-client
elsaticSearch-client主要是针对elastcSearch提供的rest api做封装,不依赖elasticSearch提供的jar包。是用scala语言封装的一个工具包
dakongyi2014/lightling
lightling是基于spark-streaming和flink封装的一个实时计算平台。目前只是针对spark-streaming,后续会加入对flink的支持。
dakongyi2014/aiot-rust
阿里云物联网设备端 Rust SDK / Alink 协议
dakongyi2014/awesome-flink
😎 A curated list of amazingly awesome Flink and Flink ecosystem resources
dakongyi2014/cockburst
一个高性能,可靠,异步的本地持久化队列实现;重启JVM、重启服务器、或者强制KILL进程时,队列里的数据不丢失;
dakongyi2014/flink
Apache Flink
dakongyi2014/flink-demo
针对flink初学者,改造自flink官方提供的demo。后续我会将我学习flink过程中写的一些示例代码加入进来
dakongyi2014/key-value-store
Generic key-value store/cache
dakongyi2014/Quicksql
Simpler, Safer, Faster Unified SQL Analytics Engine for Multi-Datasources
dakongyi2014/spark
Mirror of Apache Spark
dakongyi2014/spark-jobserver
REST job server for Apache Spark
dakongyi2014/spark-kafka-sink
A Kafka metric sink for Apache Spark
dakongyi2014/sparta
Real Time Analytics and Data Pipelines based on Spark Streaming
dakongyi2014/spring-boot-examples-master
spring-boot-examples-master
dakongyi2014/tranquility
Tranquility helps you send real-time event streams to Druid and handles partitioning, replication, service discovery, and schema rollover, seamlessly and without downtime.