metrics-spark-receiver 是用于 metrics-spark-reporterApache Spark Streaming 接收器,能够帮助开发者通过 Apache Spark 实现自定义的 Java 指标接收功能。

为了在 Spark 应用中接收一些指标数据,您需要添加以下依赖项:


  

  fr.ippon.spark.metrics  

  metrics-spark-receiver  

  1.1  

  

然后,您可以使用 JavaStreamingContext.receiverStream() 方法与自定义接收器读取这些指标流:


ssc.receive