Pinned Loading

1. sparkStreamingKafkaPerformance sparkStreamingKafkaPerformance Public

   spark将hdfs数据高性能灌入kafka，然后spark streaming/structured streaming高速消费，关注性能，欢迎提供性能/代码优化建议

   Scala 32 23

2. troubleshooting-and-optimization troubleshooting-and-optimization Public

   记录工作中的一些故障处理以及性能调优

   7 3

3. bigdataMonitor bigdataMonitor Public

   通过cloudera manager/ResourceManager/Flink API来监控相应应用的状态并输出json给splunk

   Python 5 4

4. kuduStreaming kuduStreaming Public

   syslog->flume->kafka->spark streaming->kudu

   Scala 1

5. flume-kudu-sink flume-kudu-sink Public

   flume写入kudu的sink二次开发，增加主键自定义

   Java 4 4

6. flinkKafkaPartitionAsignAnalysis flinkKafkaPartitionAsignAnalysis Public

   Flink KafkaConsumer的partition分配代码分析

   Java 1