java.lang.Object
org.apache.nifi.controller.status.ConnectionStatus
- All Implemented Interfaces:
Cloneable
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionclone()longlonggetId()longintlongintlonggetName()longintlongintlongvoidsetBackPressureBytesThreshold(long backPressureBytesThreshold) voidsetBackPressureDataSizeThreshold(String backPressureDataSizeThreshold) voidsetBackPressureObjectThreshold(long backPressureObjectThreshold) voidsetDestinationId(String destinationId) voidsetDestinationName(String destinationName) voidsetFlowFileAvailability(FlowFileAvailability availability) voidsetGroupId(String groupId) voidvoidsetInputBytes(long inputBytes) voidsetInputCount(int inputCount) voidsetLoadBalanceStatus(LoadBalanceStatus loadBalanceStatus) voidsetMaxQueuedBytes(long maxQueueBytes) voidsetMaxQueuedCount(int maxQueuedCount) voidsetMaxQueuedDuration(long maxQueuedDuration) voidvoidsetOutputBytes(long outputBytes) voidsetOutputCount(int outputCount) voidsetPredictions(ConnectionStatusPredictions predictions) voidsetQueuedBytes(long queuedBytes) voidsetQueuedCount(int queuedCount) voidsetSourceId(String sourceId) voidsetSourceName(String sourceName) voidsetTotalQueuedDuration(long totalQueuedDuration) toString()
-
Constructor Details
-
ConnectionStatus
public ConnectionStatus()
-
-
Method Details
-
getId
-
setId
-
getGroupId
-
setGroupId
-
getLoadBalanceStatus
-
setLoadBalanceStatus
-
getQueuedCount
public int getQueuedCount() -
setQueuedCount
public void setQueuedCount(int queuedCount) -
getQueuedBytes
public long getQueuedBytes() -
setQueuedBytes
public void setQueuedBytes(long queuedBytes) -
getName
-
setName
-
getSourceId
-
setSourceId
-
getSourceName
-
setSourceName
-
getDestinationId
-
setDestinationId
-
getDestinationName
-
setDestinationName
-
getBackPressureDataSizeThreshold
-
setBackPressureDataSizeThreshold
-
getPredictions
-
setPredictions
-
getBackPressureObjectThreshold
public long getBackPressureObjectThreshold() -
setBackPressureObjectThreshold
public void setBackPressureObjectThreshold(long backPressureObjectThreshold) -
getInputBytes
public long getInputBytes() -
setInputBytes
public void setInputBytes(long inputBytes) -
getInputCount
public int getInputCount() -
setInputCount
public void setInputCount(int inputCount) -
getOutputBytes
public long getOutputBytes() -
setOutputBytes
public void setOutputBytes(long outputBytes) -
getOutputCount
public int getOutputCount() -
setOutputCount
public void setOutputCount(int outputCount) -
getMaxQueuedCount
public int getMaxQueuedCount() -
setMaxQueuedCount
public void setMaxQueuedCount(int maxQueuedCount) -
getMaxQueuedBytes
public long getMaxQueuedBytes() -
setMaxQueuedBytes
public void setMaxQueuedBytes(long maxQueueBytes) -
getBackPressureBytesThreshold
public long getBackPressureBytesThreshold() -
setBackPressureBytesThreshold
public void setBackPressureBytesThreshold(long backPressureBytesThreshold) -
getTotalQueuedDuration
public long getTotalQueuedDuration() -
setTotalQueuedDuration
public void setTotalQueuedDuration(long totalQueuedDuration) -
getMaxQueuedDuration
public long getMaxQueuedDuration() -
setMaxQueuedDuration
public void setMaxQueuedDuration(long maxQueuedDuration) -
getFlowFileAvailability
-
setFlowFileAvailability
-
clone
-
toString
-