ReaderMetricsContext

java.lang.Object
- org.apache.iceberg.flink.source.reader.ReaderMetricsContext

All Implemented Interfaces:: java.io.Serializable, MetricsContext

@Internal
public class ReaderMetricsContext
extends java.lang.Object
implements MetricsContext

See Also:: Serialized Form

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.iceberg.metrics.MetricsContext
  MetricsContext.Counter<T extends java.lang.Number>, MetricsContext.Unit

Field Summary

Fields
Modifier and Type	Field	Description
`static java.lang.String`	`ASSIGNED_BYTES`
`static java.lang.String`	`ASSIGNED_SPLITS`
`static java.lang.String`	`FINISHED_BYTES`
`static java.lang.String`	`FINISHED_SPLITS`
`static java.lang.String`	`SPLIT_READER_FETCH_CALLS`

Constructor Summary

Constructors
Constructor Description

ReaderMetricsContext(org.apache.flink.metrics.MetricGroup metricGroup)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`<T extends java.lang.Number> MetricsContext.Counter<T>`	`counter(java.lang.String name, java.lang.Class<T> type, MetricsContext.Unit unit)`	Get a named counter of a specific type.

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
initialize

Field Detail

ASSIGNED_SPLITS

public static final java.lang.String ASSIGNED_SPLITS

See Also:: Constant Field Values

ASSIGNED_BYTES

public static final java.lang.String ASSIGNED_BYTES

See Also:: Constant Field Values

FINISHED_SPLITS

public static final java.lang.String FINISHED_SPLITS

See Also:: Constant Field Values

FINISHED_BYTES

public static final java.lang.String FINISHED_BYTES

See Also:: Constant Field Values

SPLIT_READER_FETCH_CALLS

public static final java.lang.String SPLIT_READER_FETCH_CALLS

See Also:: Constant Field Values

Constructor Detail

ReaderMetricsContext

public ReaderMetricsContext(org.apache.flink.metrics.MetricGroup metricGroup)

Method Detail
- counter
```
public <T extends java.lang.Number> MetricsContext.Counter<T> counter(java.lang.String name,
                                                                      java.lang.Class<T> type,
                                                                      MetricsContext.Unit unit)
```
  Description copied from interface: MetricsContext
  
  Get a named counter of a specific type. Metric implementations may impose restrictions on what types are supported for specific counters.
  
  Specified by:
  
  counter in interface MetricsContext
  
  Parameters:
  
  name - name of the metric
  
  type - numeric type of the counter value
  
  unit - the unit designation of the metric
  
  Returns:
  
  a counter implementation