Package org.apache.druid.segment.incremental

Class NoopRowIngestionMeters

java.lang.Object

org.apache.druid.segment.incremental.NoopRowIngestionMeters

All Implemented Interfaces:

InputStats, RowIngestionMeters

public class NoopRowIngestionMeters
extends Object
implements RowIngestionMeters

This class is used only in DartFrameContext. Consider using RowIngestionMetersFactory instead.

Field Summary

Fields inherited from interface org.apache.druid.segment.incremental.RowIngestionMeters

BUILD_SEGMENTS, DETERMINE_PARTITIONS, PROCESSED, PROCESSED_BYTES, PROCESSED_WITH_ERROR, THROWN_AWAY, THROWN_AWAY_BY_REASON, UNPARSEABLE

Constructor Summary

Constructors

Constructor	Description
NoopRowIngestionMeters()

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	getMovingAverages()
long	getProcessed()
long	getProcessedWithError()
long	getThrownAway()
Map<String,Long>	getThrownAwayByReason()	Returns the count of thrown away events for each reason.
RowIngestionMetersTotals	getTotals()
long	getUnparseable()
void	incrementProcessed()
void	incrementProcessedWithError()
void	incrementThrownAway(InputRowFilterResult reason)	Increments the thrown away counter for the specified InputRowFilterResult reason.
void	incrementUnparseable()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.segment.incremental.RowIngestionMeters

getProcessedBytes, incrementProcessedBytes

Constructor Details

NoopRowIngestionMeters

public NoopRowIngestionMeters()

Method Details

getProcessed

public long getProcessed()

Specified by:

getProcessed in interface RowIngestionMeters

incrementProcessed

public void incrementProcessed()

Specified by:

incrementProcessed in interface RowIngestionMeters

getProcessedWithError

public long getProcessedWithError()

Specified by:

getProcessedWithError in interface RowIngestionMeters

incrementProcessedWithError

public void incrementProcessedWithError()

Specified by:

incrementProcessedWithError in interface RowIngestionMeters

getUnparseable

public long getUnparseable()

Specified by:

getUnparseable in interface RowIngestionMeters

incrementUnparseable

public void incrementUnparseable()

Specified by:

incrementUnparseable in interface RowIngestionMeters

getThrownAway

public long getThrownAway()

Specified by:

getThrownAway in interface RowIngestionMeters

incrementThrownAway

public void incrementThrownAway(InputRowFilterResult reason)

Description copied from interface: RowIngestionMeters

Increments the thrown away counter for the specified InputRowFilterResult reason.

Specified by:

incrementThrownAway in interface RowIngestionMeters

getThrownAwayByReason

public Map<String,Long> getThrownAwayByReason()

Description copied from interface: RowIngestionMeters

Returns the count of thrown away events for each reason. Keyed by InputRowFilterResult.getReason().

Specified by:

getThrownAwayByReason in interface RowIngestionMeters

getTotals

public RowIngestionMetersTotals getTotals()

Specified by:

getTotals in interface RowIngestionMeters

getMovingAverages

public Map<String,Object> getMovingAverages()

Specified by:

getMovingAverages in interface RowIngestionMeters