Pinned Loading

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

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

   Scala 4 1

2. kubernetes-hadoop Public

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

   Shell 6 3

3. 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 7 1

4. hanlp-remote-dict Public

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

   Java 7 5

5. chrome-extensions-youdaowithwordnode Public

   有道词典chrome划词插件，原版不带生词本，逆向在其源�?�基础上，添�?了添�?生词本的功能，生词本用的有道官方API

   JavaScript 76 24

6. nifi-mutate-bundle Public

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

   Java