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 java.lang.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 and Description
NumSplits()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

NumSplits

public NumSplits()

Method Detail

name

public java.lang.String name()

Specified by:

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

description

public java.lang.String description()

Specified by:

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

aggregateTaskMetrics

public java.lang.String aggregateTaskMetrics(long[] taskMetrics)

Specified by:

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