org.apache.iceberg

Class MetricsUtil

java.lang.Object

org.apache.iceberg.MetricsUtil

public class MetricsUtil
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static java.util.Map<java.lang.Integer,java.lang.Long>	createNanValueCounts(java.util.stream.Stream<FieldMetrics<?>> fieldMetrics, MetricsConfig metricsConfig, Schema inputSchema) Construct mapping relationship between column id to NaN value counts from input metrics and metrics config.
static MetricsModes.MetricsMode	metricsMode(Schema inputSchema, MetricsConfig metricsConfig, int fieldId) Extract MetricsMode for the given field id from metrics config.

Methods inherited from class java.lang.Object

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

Method Detail

createNanValueCounts

public static java.util.Map<java.lang.Integer,java.lang.Long> createNanValueCounts(java.util.stream.Stream<FieldMetrics<?>> fieldMetrics,
                                                                                   MetricsConfig metricsConfig,
                                                                                   Schema inputSchema)

Construct mapping relationship between column id to NaN value counts from input metrics and metrics config.

metricsMode

public static MetricsModes.MetricsMode metricsMode(Schema inputSchema,
                                                   MetricsConfig metricsConfig,
                                                   int fieldId)

Extract MetricsMode for the given field id from metrics config.