metrics spark receiver 为Apache Spark Streaming提供自定义指标接收器
metrics-spark-receiver 是用于 metrics-spark-reporter 的 Apache Spark Streaming 接收器,能够帮助开发者通过 Apache Spark 实现自定义的 Java 指标接收功能。
为了在 Spark 应用中接收一些指标数据,您需要添加以下依赖项:
fr.ippon.spark.metrics
metrics-spark-receiver
1.1
然后,您可以使用 JavaStreamingContext.receiverStream() 方法与自定义接收器读取这些指标流:
ssc.receive