java.lang.Object
org.apache.nifi.controller.status.ProcessorStatus
- All Implemented Interfaces:
Cloneable
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionclone()intlonglonggetAverageLineageDuration(TimeUnit timeUnit) longlonglonglongintintintgetId()longintintgetName()longintlongintgetType()voidsetActiveThreadCount(int activeThreadCount) voidsetAverageLineageDuration(long millis) voidsetAverageLineageDuration(long duration, TimeUnit timeUnit) voidsetBytesRead(long bytesRead) voidsetBytesReceived(long bytesReceived) voidsetBytesSent(long bytesSent) voidsetBytesWritten(long bytesWritten) voidsetCounters(Map<String, Long> counters) voidsetExecutionNode(ExecutionNode executionNode) voidsetFlowFilesReceived(int flowFilesReceived) voidsetFlowFilesRemoved(int flowFilesRemoved) voidsetFlowFilesSent(int flowFilesSent) voidsetGroupId(String groupId) voidvoidsetInputBytes(long inputBytes) voidsetInputCount(int inputCount) voidsetInvocations(int invocations) voidvoidsetOutputBytes(long outputBytes) voidsetOutputCount(int outputCount) voidsetProcessingNanos(long processingNanos) voidsetProcessingPerformanceStatus(ProcessingPerformanceStatus processingPerformanceStatus) voidsetRunStatus(RunStatus runStatus) voidsetTerminatedThreadCount(int terminatedThreadCount) voidtoString()
-
Constructor Details
-
ProcessorStatus
public ProcessorStatus()
-
-
Method Details
-
getId
-
setId
-
getGroupId
-
setGroupId
-
getName
-
setName
-
getType
-
setType
-
getInputCount
public int getInputCount() -
getRunStatus
-
setRunStatus
-
getExecutionNode
-
setExecutionNode
-
setInputCount
public void setInputCount(int inputCount) -
getInputBytes
public long getInputBytes() -
setInputBytes
public void setInputBytes(long inputBytes) -
getOutputCount
public int getOutputCount() -
setOutputCount
public void setOutputCount(int outputCount) -
getOutputBytes
public long getOutputBytes() -
setOutputBytes
public void setOutputBytes(long outputBytes) -
getBytesRead
public long getBytesRead() -
setBytesRead
public void setBytesRead(long bytesRead) -
getBytesWritten
public long getBytesWritten() -
setBytesWritten
public void setBytesWritten(long bytesWritten) -
getInvocations
public int getInvocations() -
setInvocations
public void setInvocations(int invocations) -
getProcessingNanos
public long getProcessingNanos() -
setProcessingNanos
public void setProcessingNanos(long processingNanos) -
getAverageLineageDuration
-
setAverageLineageDuration
-
getAverageLineageDuration
public long getAverageLineageDuration() -
setAverageLineageDuration
public void setAverageLineageDuration(long millis) -
getFlowFilesRemoved
public int getFlowFilesRemoved() -
setFlowFilesRemoved
public void setFlowFilesRemoved(int flowFilesRemoved) -
getActiveThreadCount
public int getActiveThreadCount() -
setActiveThreadCount
public void setActiveThreadCount(int activeThreadCount) -
getTerminatedThreadCount
public int getTerminatedThreadCount() -
setTerminatedThreadCount
public void setTerminatedThreadCount(int terminatedThreadCount) -
getFlowFilesReceived
public int getFlowFilesReceived() -
setFlowFilesReceived
public void setFlowFilesReceived(int flowFilesReceived) -
getBytesReceived
public long getBytesReceived() -
setBytesReceived
public void setBytesReceived(long bytesReceived) -
getFlowFilesSent
public int getFlowFilesSent() -
setFlowFilesSent
public void setFlowFilesSent(int flowFilesSent) -
getBytesSent
public long getBytesSent() -
setBytesSent
public void setBytesSent(long bytesSent) -
getCounters
-
setCounters
-
getProcessingPerformanceStatus
-
setProcessingPerformanceStatus
-
clone
-
toString
-