Class CustomAvgMetric

Object
org.apache.spark.sql.connector.metric.CustomAvgMetric
All Implemented Interfaces:
CustomMetric

@Evolving public abstract class CustomAvgMetric extends Object implements CustomMetric
Built-in `CustomMetric` that computes average of metric values. Note that please extend this class and override `name` and `description` to create your custom metric for real usage.
Since:
3.2.0
  • Constructor Details

    • CustomAvgMetric

      public CustomAvgMetric()
  • Method Details

    • aggregateTaskMetrics

      public String aggregateTaskMetrics(long[] taskMetrics)
      Description copied from interface: CustomMetric
      Given an array of task metric values, returns aggregated final metric value.
      Specified by:
      aggregateTaskMetrics in interface CustomMetric