Package org.apache.nifi.util.timebuffer

Class TimedBuffer.EntitySum<S>

java.lang.Object

org.apache.nifi.util.timebuffer.TimedBuffer.EntitySum<S>

Enclosing class:

TimedBuffer<T>

private static class TimedBuffer.EntitySum<S>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final TimeUnit	binPrecision
private final LongSupplier	currentTimeSupplier
private final EntityAccess<S>	entityAccess
private final int	numConfiguredBins
private final AtomicReference<S>	ref

Constructor Summary

Constructors

Constructor	Description
EntitySum(TimeUnit binPrecision, int numConfiguredBins, EntityAccess<S> aggregator, LongSupplier currentTimeSupplier)

Method Summary

Modifier and Type	Method	Description
private S	add(S event)
S	addOrReset(S event)
S	getValue()
boolean	isExpired()

Methods inherited from class java.lang.Object

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

Field Details

entityAccess

private final EntityAccess<S> entityAccess

ref

private final AtomicReference<S> ref

binPrecision

private final TimeUnit binPrecision

numConfiguredBins

private final int numConfiguredBins

currentTimeSupplier

private final LongSupplier currentTimeSupplier

Constructor Details

EntitySum

public EntitySum(TimeUnit binPrecision,
 int numConfiguredBins,
 EntityAccess<S> aggregator,
 LongSupplier currentTimeSupplier)

Method Details

add

private S add(S event)

getValue

public S getValue()

isExpired

public boolean isExpired()

addOrReset

public S addOrReset(S event)