Pinned

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 18 6

2. kubernetes-hadoop kubernetes-hadoop Public

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

   Shell 19 8

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. nifi-mutate-bundle nifi-mutate-bundle Public

   应用官方expression-language（EL）实现类似logstash的mutate，对每行一条json对象string的flowfile,按行应用mutate规则,修改原始json对象的值,输出变更后的flowfile

   Java 2

6. gowebframework gowebframework Public

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

   Go 5 1