org.apache.nifi.controller.repository.metrics

Class StandardFlowFileEvent

java.lang.Object

org.apache.nifi.controller.repository.metrics.StandardFlowFileEvent

All Implemented Interfaces:

java.lang.Cloneable, FlowFileEvent

public final class StandardFlowFileEvent
extends java.lang.Object
implements FlowFileEvent, java.lang.Cloneable

Constructor Summary

Constructors

Constructor and Description
StandardFlowFileEvent(java.lang.String componentId)

Method Summary

Modifier and Type	Method and Description
long	getAggregateLineageMillis()
long	getAverageLineageMillis()
long	getBytesRead()
long	getBytesReceived()
long	getBytesSent()
long	getBytesWritten()
java.lang.String	getComponentIdentifier()
long	getContentSizeIn()
long	getContentSizeOut()
long	getContentSizeRemoved()
java.util.Map<java.lang.String,java.lang.Long>	getCounters()
int	getFlowFilesIn()
int	getFlowFilesOut()
int	getFlowFilesReceived()
int	getFlowFilesRemoved()
int	getFlowFilesSent()
int	getInvocations()
long	getProcessingNanoseconds()
void	setAggregateLineageMillis(long lineageMilliseconds)
void	setBytesRead(long bytesRead)
void	setBytesReceived(long bytesReceived)
void	setBytesSent(long bytesSent)
void	setBytesWritten(long bytesWritten)
void	setContentSizeIn(long contentSizeIn)
void	setContentSizeOut(long contentSizeOut)
void	setContentSizeRemoved(long contentSizeRemoved)
void	setCounters(java.util.Map<java.lang.String,java.lang.Long> counters)
void	setFlowFilesIn(int flowFilesIn)
void	setFlowFilesOut(int flowFilesOut)
void	setFlowFilesReceived(int flowFilesReceived)
void	setFlowFilesRemoved(int flowFilesRemoved)
void	setFlowFilesSent(int flowFilesSent)
void	setInvocations(int invocations)
void	setProcessingNanos(long processingNanos)

Methods inherited from class java.lang.Object

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

Constructor Detail

StandardFlowFileEvent

public StandardFlowFileEvent(java.lang.String componentId)

Method Detail

getComponentIdentifier

public java.lang.String getComponentIdentifier()

Specified by:

getComponentIdentifier in interface FlowFileEvent

getFlowFilesIn

public int getFlowFilesIn()

Specified by:

getFlowFilesIn in interface FlowFileEvent

setFlowFilesIn

public void setFlowFilesIn(int flowFilesIn)

getFlowFilesOut

public int getFlowFilesOut()

Specified by:

getFlowFilesOut in interface FlowFileEvent

setFlowFilesOut

public void setFlowFilesOut(int flowFilesOut)

getContentSizeIn

public long getContentSizeIn()

Specified by:

getContentSizeIn in interface FlowFileEvent

setContentSizeIn

public void setContentSizeIn(long contentSizeIn)

getContentSizeOut

public long getContentSizeOut()

Specified by:

getContentSizeOut in interface FlowFileEvent

setContentSizeOut

public void setContentSizeOut(long contentSizeOut)

getContentSizeRemoved

public long getContentSizeRemoved()

Specified by:

getContentSizeRemoved in interface FlowFileEvent

setContentSizeRemoved

public void setContentSizeRemoved(long contentSizeRemoved)

getFlowFilesRemoved

public int getFlowFilesRemoved()

Specified by:

getFlowFilesRemoved in interface FlowFileEvent

setFlowFilesRemoved

public void setFlowFilesRemoved(int flowFilesRemoved)

getBytesRead

public long getBytesRead()

Specified by:

getBytesRead in interface FlowFileEvent

setBytesRead

public void setBytesRead(long bytesRead)

getBytesWritten

public long getBytesWritten()

Specified by:

getBytesWritten in interface FlowFileEvent

setBytesWritten

public void setBytesWritten(long bytesWritten)

getProcessingNanoseconds

public long getProcessingNanoseconds()

Specified by:

getProcessingNanoseconds in interface FlowFileEvent

setProcessingNanos

public void setProcessingNanos(long processingNanos)

getInvocations

public int getInvocations()

Specified by:

getInvocations in interface FlowFileEvent

setInvocations

public void setInvocations(int invocations)

getFlowFilesReceived

public int getFlowFilesReceived()

Specified by:

getFlowFilesReceived in interface FlowFileEvent

setFlowFilesReceived

public void setFlowFilesReceived(int flowFilesReceived)

getBytesReceived

public long getBytesReceived()

Specified by:

getBytesReceived in interface FlowFileEvent

setBytesReceived

public void setBytesReceived(long bytesReceived)

getFlowFilesSent

public int getFlowFilesSent()

Specified by:

getFlowFilesSent in interface FlowFileEvent

setFlowFilesSent

public void setFlowFilesSent(int flowFilesSent)

getBytesSent

public long getBytesSent()

Specified by:

getBytesSent in interface FlowFileEvent

setBytesSent

public void setBytesSent(long bytesSent)

getAverageLineageMillis

public long getAverageLineageMillis()

Specified by:

getAverageLineageMillis in interface FlowFileEvent

setAggregateLineageMillis

public void setAggregateLineageMillis(long lineageMilliseconds)

getAggregateLineageMillis

public long getAggregateLineageMillis()

Specified by:

getAggregateLineageMillis in interface FlowFileEvent

getCounters

public java.util.Map<java.lang.String,java.lang.Long> getCounters()

Specified by:

getCounters in interface FlowFileEvent

setCounters

public void setCounters(java.util.Map<java.lang.String,java.lang.Long> counters)