Package org.apache.druid.indexer

Class TaskMetricsUtils

java.lang.Object

org.apache.druid.indexer.TaskMetricsUtils

public class TaskMetricsUtils
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ROWS_PROCESSED
static final String	ROWS_PROCESSED_WITH_ERRORS
static final String	ROWS_THROWN_AWAY
static final String	ROWS_UNPARSEABLE

Constructor Summary

Constructors

Constructor	Description
TaskMetricsUtils()

Method Summary

Modifier and Type	Method	Description
static Map<String,Object>	makeIngestionRowMetrics(long rowsProcessed, long rowsProcessedWithErrors, long rowsUnparseable, long rowsThrownAway)

Methods inherited from class java.lang.Object

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

Field Details

ROWS_PROCESSED

public static final String ROWS_PROCESSED

See Also:

• Constant Field Values

ROWS_PROCESSED_WITH_ERRORS

public static final String ROWS_PROCESSED_WITH_ERRORS

See Also:

• Constant Field Values

ROWS_UNPARSEABLE

public static final String ROWS_UNPARSEABLE

See Also:

• Constant Field Values

ROWS_THROWN_AWAY

public static final String ROWS_THROWN_AWAY

See Also:

• Constant Field Values

Constructor Details

TaskMetricsUtils

public TaskMetricsUtils()

Method Details

makeIngestionRowMetrics

public static Map<String,Object> makeIngestionRowMetrics(long rowsProcessed,
 long rowsProcessedWithErrors,
 long rowsUnparseable,
 long rowsThrownAway)