Package org.apache.iceberg.spark.source.metrics

Class NumSplits

java.lang.Object

org.apache.iceberg.spark.source.metrics.NumSplits

All Implemented Interfaces:

org.apache.spark.sql.connector.metric.CustomMetric

public class NumSplits
extends Object
implements org.apache.spark.sql.connector.metric.CustomMetric

Field Summary

Fields inherited from interface org.apache.spark.sql.connector.metric.CustomMetric

initialValue

Constructor Summary

Constructors

Constructor	Description
NumSplits()

Method Summary

Modifier and Type	Method	Description
String	aggregateTaskMetrics(long[] taskMetrics)
String	description()
String	name()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

NumSplits

public NumSplits()

Method Details

name

public String name()

Specified by:

name in interface org.apache.spark.sql.connector.metric.CustomMetric

description

public String description()

Specified by:

description in interface org.apache.spark.sql.connector.metric.CustomMetric

aggregateTaskMetrics

public String aggregateTaskMetrics(long[] taskMetrics)

Specified by:

aggregateTaskMetrics in interface org.apache.spark.sql.connector.metric.CustomMetric