This is an automated email from the ASF dual-hosted git repository.
aichrist pushed a commit to branch analytics-framework
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/analytics-framework by this
push:
new 16f7c37 NIFI-6510 Rip out useless members
16f7c37 is described below
commit 16f7c37f05aa722a748d309297c4b0b92675c153
Author: Andrew I. Christianson <[email protected]>
AuthorDate: Mon Sep 9 11:16:40 2019 -0400
NIFI-6510 Rip out useless members
---
.../status/ConnectionStatisticsSnapshotDTO.java | 85 ----------------------
.../org/apache/nifi/web/api/dto/DtoFactory.java | 4 -
2 files changed, 89 deletions(-)
diff --git
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ConnectionStatisticsSnapshotDTO.java
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ConnectionStatisticsSnapshotDTO.java
index a521db4..656fec2 100644
---
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ConnectionStatisticsSnapshotDTO.java
+++
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ConnectionStatisticsSnapshotDTO.java
@@ -27,13 +27,6 @@ import io.swagger.annotations.ApiModelProperty;
public class ConnectionStatisticsSnapshotDTO implements Cloneable {
private String id;
- private String groupId;
- private String name;
-
- private String sourceId;
- private String sourceName;
- private String destinationId;
- private String destinationName;
private Long predictedMillisUntilCountBackpressure = 0L;
private Long predictedMillisUntilBytesBackpressure = 0L;
@@ -56,78 +49,6 @@ public class ConnectionStatisticsSnapshotDTO implements
Cloneable {
this.id = id;
}
- /**
- * @return the ID of the Process Group to which this connection belongs.
- */
- @ApiModelProperty("The id of the process group the connection belongs to.")
- public String getGroupId() {
- return groupId;
- }
-
- public void setGroupId(final String groupId) {
- this.groupId = groupId;
- }
-
- /**
- * @return name of this connection
- */
- @ApiModelProperty("The name of the connection.")
- public String getName() {
- return name;
- }
-
- public void setName(String name) {
- this.name = name;
- }
-
- /**
- * @return id of the source of this connection
- */
- @ApiModelProperty("The id of the source of the connection.")
- public String getSourceId() {
- return sourceId;
- }
-
- public void setSourceId(String sourceId) {
- this.sourceId = sourceId;
- }
-
- /**
- * @return name of the source of this connection
- */
- @ApiModelProperty("The name of the source of the connection.")
- public String getSourceName() {
- return sourceName;
- }
-
- public void setSourceName(String sourceName) {
- this.sourceName = sourceName;
- }
-
- /**
- * @return id of the destination of this connection
- */
- @ApiModelProperty("The id of the destination of the connection.")
- public String getDestinationId() {
- return destinationId;
- }
-
- public void setDestinationId(String destinationId) {
- this.destinationId = destinationId;
- }
-
- /**
- * @return name of the destination of this connection
- */
- @ApiModelProperty("The name of the destination of the connection.")
- public String getDestinationName() {
- return destinationName;
- }
-
- public void setDestinationName(String destinationName) {
- this.destinationName = destinationName;
- }
-
@ApiModelProperty("The predicted number of milliseconds before the
connection will have backpressure applied, based on the queued count.")
public Long getPredictedMillisUntilCountBackpressure() {
return predictedMillisUntilCountBackpressure;
@@ -194,13 +115,7 @@ public class ConnectionStatisticsSnapshotDTO implements
Cloneable {
@Override
public ConnectionStatisticsSnapshotDTO clone() {
final ConnectionStatisticsSnapshotDTO other = new
ConnectionStatisticsSnapshotDTO();
- other.setDestinationId(getDestinationId());
- other.setDestinationName(getDestinationName());
- other.setGroupId(getGroupId());
other.setId(getId());
- other.setName(getName());
- other.setSourceId(getSourceId());
- other.setSourceName(getSourceName());
other.setPredictedMillisUntilCountBackpressure(getPredictedMillisUntilCountBackpressure());
other.setPredictedMillisUntilBytesBackpressure(getPredictedMillisUntilBytesBackpressure());
diff --git
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java
index 42253d7..957ea09 100644
---
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java
+++
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java
@@ -1229,10 +1229,6 @@ public final class DtoFactory {
connectionStatisticsDTO.setAggregateSnapshot(snapshot);
snapshot.setId(connection.getIdentifier());
- snapshot.setGroupId(connection.getProcessGroup().getIdentifier());
- snapshot.setName(connection.getName());
- snapshot.setSourceName(connection.getSource().getName());
- snapshot.setDestinationName(connection.getDestination().getName());
Map<String,Long> predictions = statusAnalytics.getPredictions();
snapshot.setPredictedMillisUntilBytesBackpressure(predictions.get("timeToBytesBackpressureMillis"));
