in src/main/java/org/apache/nifi/controller/status/ProcessGroupStatus.java [285:358]
public ProcessGroupStatus clone() {
final ProcessGroupStatus clonedObj = new ProcessGroupStatus();
clonedObj.id = id;
clonedObj.name = name;
clonedObj.outputContentSize = outputContentSize;
clonedObj.outputCount = outputCount;
clonedObj.inputContentSize = inputContentSize;
clonedObj.inputCount = inputCount;
clonedObj.activeThreadCount = activeThreadCount;
clonedObj.terminatedThreadCount = terminatedThreadCount;
clonedObj.queuedContentSize = queuedContentSize;
clonedObj.queuedCount = queuedCount;
clonedObj.bytesRead = bytesRead;
clonedObj.bytesWritten = bytesWritten;
clonedObj.flowFilesReceived = flowFilesReceived;
clonedObj.bytesReceived = bytesReceived;
clonedObj.flowFilesSent = flowFilesSent;
clonedObj.bytesSent = bytesSent;
clonedObj.flowFilesTransferred = flowFilesTransferred;
clonedObj.bytesTransferred = bytesTransferred;
clonedObj.processingNanos = processingNanos;
clonedObj.processingPerformanceStatus = processingPerformanceStatus;
if (connectionStatus != null) {
final Collection<ConnectionStatus> statusList = new ArrayList<>();
clonedObj.setConnectionStatus(statusList);
for (final ConnectionStatus status : connectionStatus) {
statusList.add(status.clone());
}
}
if (processorStatus != null) {
final Collection<ProcessorStatus> statusList = new ArrayList<>();
clonedObj.setProcessorStatus(statusList);
for (final ProcessorStatus status : processorStatus) {
statusList.add(status.clone());
}
}
if (inputPortStatus != null) {
final Collection<PortStatus> statusList = new ArrayList<>();
clonedObj.setInputPortStatus(statusList);
for (final PortStatus status : inputPortStatus) {
statusList.add(status.clone());
}
}
if (outputPortStatus != null) {
final Collection<PortStatus> statusList = new ArrayList<>();
clonedObj.setOutputPortStatus(statusList);
for (final PortStatus status : outputPortStatus) {
statusList.add(status.clone());
}
}
if (processGroupStatus != null) {
final Collection<ProcessGroupStatus> statusList = new ArrayList<>();
clonedObj.setProcessGroupStatus(statusList);
for (final ProcessGroupStatus status : processGroupStatus) {
statusList.add(status.clone());
}
}
if (remoteProcessGroupStatus != null) {
final Collection<RemoteProcessGroupStatus> statusList = new ArrayList<>();
clonedObj.setRemoteProcessGroupStatus(statusList);
for (final RemoteProcessGroupStatus status : remoteProcessGroupStatus) {
statusList.add(status.clone());
}
}
return clonedObj;
}