slim:侦听Spark事件，聚合统计信息并将其写入Mongo的节点服务器
需积分: 10 26 浏览量
2021-05-01
10:59:19
上传
评论
收藏 207KB ZIP 举报
slim-master.zip （94个子文件） 
slim-master 
.gitignore 44B README.md 10KB utils ost.js 16KB log.js 895B objs.js 2KB utils.js 2KB server.js 26KB test .gitignore 3B test.js 2KB data metrics output non_rdd_blocks.json 3B environment.json 3B stage_summary_metrics.json 6KB task_attempts.json 49KB rdds.json 1KB jobs.json 1KB stage_executors.json 1KB executors.json 967B apps.json 888B stage_attempts.json 2KB rdd_executors.json 136B tasks.json 6KB rdd_blocks.json 7KB stages.json 3KB input events.json 62KB events.json.bak 62KB skips output non_rdd_blocks.json 3B environment.json 27KB stage_summary_metrics.json 51KB task_attempts.json 842KB rdds.json 14KB jobs.json 9KB stage_executors.json 8KB executors.json 1018B apps.json 1KB stage_attempts.json 13KB rdd_executors.json 3B tasks.json 118KB rdd_blocks.json 3B stages.json 35KB input events.json 1.11MB small output non_rdd_blocks.json 3B environment.json 8KB stage_summary_metrics.json 6KB task_attempts.json 10KB rdds.json 1KB jobs.json 1KB stage_executors.json 1KB executors.json 1KB apps.json 1KB stage_attempts.json 2KB rdd_executors.json 175B tasks.json 1KB rdd_blocks.json 2KB stages.json 3KB input events.json 27KB medium output non_rdd_blocks.json 3B environment.json 30KB stage_summary_metrics.json 6KB task_attempts.json 229KB rdds.json 1KB jobs.json 2KB stage_executors.json 4KB executors.json 15KB apps.json 1KB stage_attempts.json 2KB rdd_executors.json 233B tasks.json 31KB rdd_blocks.json 45KB stages.json 3KB input events.json 325KB lib server.js 874B utils.js 642B dump-records.js 4KB LICENSE 11KB slim.js 814B package.json 1KB mongo collections.js 3KB upsert-stats.js 2KB subrecord.js 1KB record.js 13KB models rdd-executor.js 345B stage-executor.js 452B executor.js 1KB stage.js 1KB rdd.js 3KB app.js 12KB job.js 282B block.js 710B stage-summary-metric.js 3KB task.js 786B task-attempt.js 3KB stage-attempt.js 4KB .npmignore 28B .travis.yml 52B资源评论
