Pinned Loading

1. flink-connector-elasticsearch-source flink-connector-elasticsearch-source Public

   Flink Hadoop Compatibility + Elasticsearch for Apache Hadoop = Flink Connector Elasticsearch Source Table。结合flink+hadoop+es 实现的es table source,从es下载数据后应用flink sql，小数据agg，大数据etl.不支持谓词下推

   Java 20 6

2. kubernetes-hadoop kubernetes-hadoop Public

   k8s hadoop,在k8s上快速搭建一个hadoop/hbase/hive环境，很早的项目自已用，腾讯tbds培训，以此为基础(多了一个kafka/flink)搭一套环境练习，又捡起来了

   Shell 21 7

3. spark-streaming-kafka-offset-mysql spark-streaming-kafka-offset-mysql Public

   mysql 维护 kafka offset,支持追踪并回滚到某个'异常'时间点，重新消费

   Scala 4 3

4. hanlp-remote-dict hanlp-remote-dict Public

   hanlp 加载远程词库示例,功能从成熟的elasticsearch-analysis-ik里提取,web为spring-boot

   Java 9 4

5. gowebframework gowebframework Public

   参考docker源码,基于gorilla封装的轻量web框架

   Go 5 1

6. sequelize-sharding sequelize-sharding Public

   通过sequelize的hooks模块，更改读写前的table_name，实现类似spring AOP的分表读写，sequelize Model hooks for sharded-table that like [tablename]_yyyy_mm...

   JavaScript 8 1