Package org.apache.iceberg.hadoop

Class HadoopMetricsContext

java.lang.Object

org.apache.iceberg.hadoop.HadoopMetricsContext

All Implemented Interfaces:

Serializable, FileIOMetricsContext, MetricsContext

public class HadoopMetricsContext
extends Object
implements FileIOMetricsContext

FileIO Metrics implementation that delegates to Hadoop FileSystem statistics implementation using the provided scheme.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.iceberg.metrics.MetricsContext

MetricsContext.Counter<T extends Number>, MetricsContext.Unit

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SCHEME

Fields inherited from interface org.apache.iceberg.io.FileIOMetricsContext

READ_BYTES, READ_OPERATIONS, WRITE_BYTES, WRITE_OPERATIONS

Constructor Summary

Constructors

Constructor	Description
HadoopMetricsContext(String scheme)

Method Summary

Modifier and Type	Method	Description
<T extends Number> MetricsContext.Counter<T>	counter(String name, Class<T> type, MetricsContext.Unit unit)	The Hadoop implementation delegates to the FileSystem.Statistics implementation and therefore does not require support for operations like unit() and count() as the counter values are not directly consumed.
Counter	counter(String name, MetricsContext.Unit unit)	The Hadoop implementation delegates to the FileSystem.Statistics implementation and therefore does not require support for operations like unit() as the counter values are not directly consumed.
void	initialize(Map<String,String> properties)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iceberg.metrics.MetricsContext

counter, histogram, timer

Field Details

SCHEME

public static final String SCHEME

See Also:

• Constant Field Values

Constructor Details

HadoopMetricsContext

public HadoopMetricsContext(String scheme)

Method Details

initialize

public void initialize(Map<String,String> properties)

Specified by:

initialize in interface MetricsContext

counter

public <T extends Number> MetricsContext.Counter<T> counter(String name,
 Class<T> type,
 MetricsContext.Unit unit)

The Hadoop implementation delegates to the FileSystem.Statistics implementation and therefore does not require support for operations like unit() and count() as the counter values are not directly consumed.

Specified by:

counter in interface MetricsContext

Type Parameters:

T - Counter numeric type

Parameters:

name - name of the metric

type - numeric type of the counter value

unit - ignored

Returns:

counter

counter

public Counter counter(String name,
 MetricsContext.Unit unit)

The Hadoop implementation delegates to the FileSystem.Statistics implementation and therefore does not require support for operations like unit() as the counter values are not directly consumed.

Specified by:

counter in interface MetricsContext

Parameters:

name - name of the metric

unit - ignored

Returns:

counter