org.apache.paimon.operation.metrics

Class CompactionMetrics

java.lang.Object

org.apache.paimon.operation.metrics.CompactionMetrics

public class CompactionMetrics
extends Object

Metrics to measure a compaction.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	CompactionMetrics.Reporter Report metrics value to the CompactionMetrics object.

Field Summary

Fields

Modifier and Type	Field and Description
static String	AVG_COMPACTION_INPUT_SIZE
static String	AVG_COMPACTION_OUTPUT_SIZE
static String	AVG_COMPACTION_TIME
static String	AVG_LEVEL0_FILE_COUNT
static String	COMPACTION_COMPLETED_COUNT
static String	COMPACTION_QUEUED_COUNT
static String	COMPACTION_THREAD_BUSY
static String	MAX_COMPACTION_INPUT_SIZE
static String	MAX_COMPACTION_OUTPUT_SIZE
static String	MAX_LEVEL0_FILE_COUNT

Constructor Summary

Constructors

Constructor and Description
CompactionMetrics(MetricRegistry registry, String tableName)

Method Summary

Modifier and Type	Method and Description
void	close()
CompactionMetrics.Reporter	createReporter(BinaryRow partition, int bucket)
MetricGroup	getMetricGroup()

Methods inherited from class java.lang.Object

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

Field Detail

MAX_LEVEL0_FILE_COUNT

public static final String MAX_LEVEL0_FILE_COUNT

See Also:

Constant Field Values

AVG_LEVEL0_FILE_COUNT

public static final String AVG_LEVEL0_FILE_COUNT

See Also:

Constant Field Values

COMPACTION_THREAD_BUSY

public static final String COMPACTION_THREAD_BUSY

See Also:

Constant Field Values

AVG_COMPACTION_TIME

public static final String AVG_COMPACTION_TIME

See Also:

Constant Field Values

COMPACTION_COMPLETED_COUNT

public static final String COMPACTION_COMPLETED_COUNT

See Also:

Constant Field Values

COMPACTION_QUEUED_COUNT

public static final String COMPACTION_QUEUED_COUNT

See Also:

Constant Field Values

MAX_COMPACTION_INPUT_SIZE

public static final String MAX_COMPACTION_INPUT_SIZE

See Also:

Constant Field Values

MAX_COMPACTION_OUTPUT_SIZE

public static final String MAX_COMPACTION_OUTPUT_SIZE

See Also:

Constant Field Values

AVG_COMPACTION_INPUT_SIZE

public static final String AVG_COMPACTION_INPUT_SIZE

See Also:

Constant Field Values

AVG_COMPACTION_OUTPUT_SIZE

public static final String AVG_COMPACTION_OUTPUT_SIZE

See Also:

Constant Field Values

Constructor Detail

CompactionMetrics

public CompactionMetrics(MetricRegistry registry,
                         String tableName)

Method Detail

getMetricGroup

@VisibleForTesting
public MetricGroup getMetricGroup()

close

public void close()

createReporter

public CompactionMetrics.Reporter createReporter(BinaryRow partition,
                                                 int bucket)