Package org.apache.druid.segment.incremental

Class SimpleRowIngestionMeters

java.lang.Object

org.apache.druid.segment.incremental.SimpleRowIngestionMeters

All Implemented Interfaces:

InputStats, RowIngestionMeters

public class SimpleRowIngestionMeters
extends Object
implements RowIngestionMeters

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
SimpleRowIngestionMeters()

Method Summary

Modifier and Type	Method	Description
void	addRowIngestionMetersTotals(RowIngestionMetersTotals rowIngestionMetersTotals)
Map<String,Object>	getMovingAverages()
long	getProcessed()
long	getProcessedBytes()
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	incrementProcessedBytes(long increment)
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

Constructor Details

SimpleRowIngestionMeters

public SimpleRowIngestionMeters()

Method Details

getProcessed

public long getProcessed()

Specified by:

getProcessed in interface RowIngestionMeters

incrementProcessed

public void incrementProcessed()

Specified by:

incrementProcessed in interface RowIngestionMeters

incrementProcessedBytes

public void incrementProcessedBytes(long increment)

Specified by:

incrementProcessedBytes in interface InputStats

Specified by:

incrementProcessedBytes in interface RowIngestionMeters

getProcessedBytes

public long getProcessedBytes()

Specified by:

getProcessedBytes in interface InputStats

Specified by:

getProcessedBytes 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

addRowIngestionMetersTotals

public void addRowIngestionMetersTotals(RowIngestionMetersTotals rowIngestionMetersTotals)