http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceEventDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceEventDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceEventDTO.java deleted file mode 100644 index b1ead42..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceEventDTO.java +++ /dev/null @@ -1,630 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.provenance; - -import java.util.Collection; -import java.util.Date; -import java.util.List; - -import javax.xml.bind.annotation.XmlType; -import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter; - -import org.apache.nifi.web.api.dto.util.TimestampAdapter; - -/** - * A provenance event. - */ -@XmlType(name = "provenanceEvent") -public class ProvenanceEventDTO { - - private String id; - - // in search results table - private Long eventId; - private Date eventTime; - private Long eventDuration; - private Long lineageDuration; - private String eventType; - private String flowFileUuid; - private String fileSize; - private Long fileSizeBytes; - private String clusterNodeId; // include when clustered - private String clusterNodeAddress; // include when clustered - - private String groupId; - private String componentId; - private String componentType; - private String componentName; - private String sourceSystemFlowFileId; - private String alternateIdentifierUri; - private Collection<AttributeDTO> attributes; - private List<String> parentUuids; - private List<String> childUuids; - - private String transitUri; - - private String relationship; - private String details; - - // content - private Boolean contentEqual; - private Boolean inputContentAvailable; - private String inputContentClaimSection; - private String inputContentClaimContainer; - private String inputContentClaimIdentifier; - private Long inputContentClaimOffset; - private String inputContentClaimFileSize; - private Long inputContentClaimFileSizeBytes; - private Boolean outputContentAvailable; - private String outputContentClaimSection; - private String outputContentClaimContainer; - private String outputContentClaimIdentifier; - private Long outputContentClaimOffset; - private String outputContentClaimFileSize; - private Long outputContentClaimFileSizeBytes; - - // replay - private Boolean replayAvailable; - private String replayExplanation; - private String sourceConnectionIdentifier; - - /** - * The event uuid. - * - * @return - */ - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id; - } - - /** - * The event id. - * - * @return - */ - public Long getEventId() { - return eventId; - } - - public void setEventId(Long eventId) { - this.eventId = eventId; - } - - /** - * The time the event occurred. - * - * @return - */ - @XmlJavaTypeAdapter(TimestampAdapter.class) - public Date getEventTime() { - return eventTime; - } - - public void setEventTime(Date eventTime) { - this.eventTime = eventTime; - } - - /** - * The UUID of the FlowFile for this event. - * - * @return - */ - public String getFlowFileUuid() { - return flowFileUuid; - } - - public void setFlowFileUuid(String flowFileUuid) { - this.flowFileUuid = flowFileUuid; - } - - /** - * The size of the FlowFile for this event. - * - * @return - */ - public String getFileSize() { - return fileSize; - } - - public void setFileSize(String fileSize) { - this.fileSize = fileSize; - } - - /** - * The size of the FlowFile in bytes for this event. - * - * @return - */ - public Long getFileSizeBytes() { - return fileSizeBytes; - } - - public void setFileSizeBytes(Long fileSizeBytes) { - this.fileSizeBytes = fileSizeBytes; - } - - /** - * The type of this event. - * - * @return - */ - public String getEventType() { - return eventType; - } - - public void setEventType(String eventType) { - this.eventType = eventType; - } - - /** - * The attributes for the FlowFile for this event. - * - * @return - */ - public Collection<AttributeDTO> getAttributes() { - return attributes; - } - - public void setAttributes(Collection<AttributeDTO> attributes) { - this.attributes = attributes; - } - - /** - * The id of the group that this component resides in. If the component is - * no longer in the flow, the group id will not be set. - * - * @return - */ - public String getGroupId() { - return groupId; - } - - public void setGroupId(String groupId) { - this.groupId = groupId; - } - - /** - * The id of the component that generated this event. - * - * @return - */ - public String getComponentId() { - return componentId; - } - - public void setComponentId(String componentId) { - this.componentId = componentId; - } - - /** - * The name of the component that generated this event. - * - * @return - */ - public String getComponentName() { - return componentName; - } - - public void setComponentName(String componentName) { - this.componentName = componentName; - } - - /** - * The type of the component that generated this event. - * - * @return - */ - public String getComponentType() { - return componentType; - } - - public void setComponentType(String componentType) { - this.componentType = componentType; - } - - /** - * The source/destination system URI if the event was a RECEIVE/SEND. - * - * @return - */ - public String getTransitUri() { - return transitUri; - } - - public void setTransitUri(String transitUri) { - this.transitUri = transitUri; - } - - /** - * The alternate identifier URI for the FlowFile for this event. - * - * @return - */ - public String getAlternateIdentifierUri() { - return alternateIdentifierUri; - } - - public void setAlternateIdentifierUri(String alternateIdentifierUri) { - this.alternateIdentifierUri = alternateIdentifierUri; - } - - /** - * The identifier of the node where this event originated. - * - * @return - */ - public String getClusterNodeId() { - return clusterNodeId; - } - - public void setClusterNodeId(String clusterNodeId) { - this.clusterNodeId = clusterNodeId; - } - - /** - * The label to use to show which node this event originated from. - * - * @return - */ - public String getClusterNodeAddress() { - return clusterNodeAddress; - } - - public void setClusterNodeAddress(String clusterNodeAddress) { - this.clusterNodeAddress = clusterNodeAddress; - } - - /** - * The parent uuids for this event. - * - * @return - */ - public List<String> getParentUuids() { - return parentUuids; - } - - public void setParentUuids(List<String> parentUuids) { - this.parentUuids = parentUuids; - } - - /** - * The child uuids for this event. - * - * @return - */ - public List<String> getChildUuids() { - return childUuids; - } - - public void setChildUuids(List<String> childUuids) { - this.childUuids = childUuids; - } - - /** - * The duration of the event, in milliseconds. - * - * @return - */ - public Long getEventDuration() { - return eventDuration; - } - - public void setEventDuration(Long eventDuration) { - this.eventDuration = eventDuration; - } - - /** - * The duration since the lineage began, in milliseconds. - * - * @return - */ - public Long getLineageDuration() { - return lineageDuration; - } - - public void setLineageDuration(Long lineageDuration) { - this.lineageDuration = lineageDuration; - } - - /** - * The source system FlowFile id. - * - * @return - */ - public String getSourceSystemFlowFileId() { - return sourceSystemFlowFileId; - } - - public void setSourceSystemFlowFileId(String sourceSystemFlowFileId) { - this.sourceSystemFlowFileId = sourceSystemFlowFileId; - } - - /** - * If this represents a route event, this is the relationship to which the - * flowfile was routed. - * - * @return - */ - public String getRelationship() { - return relationship; - } - - public void setRelationship(String relationship) { - this.relationship = relationship; - } - - /** - * The event details. - * - * @return - */ - public String getDetails() { - return details; - } - - public void setDetails(String details) { - this.details = details; - } - - /** - * Whether or not the input and output content claim is the same. - * - * @return - */ - public Boolean getContentEqual() { - return contentEqual; - } - - public void setContentEqual(Boolean contentEqual) { - this.contentEqual = contentEqual; - } - - /** - * Returns whether or not the output content is still available. - * - * @return - */ - public Boolean getOutputContentAvailable() { - return outputContentAvailable; - } - - public void setOutputContentAvailable(Boolean outputContentAvailable) { - this.outputContentAvailable = outputContentAvailable; - } - - /** - * Returns the Section in which the output Content Claim lives, or - * <code>null</code> if no Content Claim exists. - * - * @return - */ - public String getOutputContentClaimSection() { - return outputContentClaimSection; - } - - public void setOutputContentClaimSection(String contentClaimSection) { - this.outputContentClaimSection = contentClaimSection; - } - - /** - * Returns the Container in which the output Content Claim lives, or - * <code>null</code> if no Content Claim exists. - * - * @return - */ - public String getOutputContentClaimContainer() { - return outputContentClaimContainer; - } - - public void setOutputContentClaimContainer(String outputContentClaimContainer) { - this.outputContentClaimContainer = outputContentClaimContainer; - } - - /** - * Returns the Identifier of the output Content Claim, or <code>null</code> - * if no Content Claim exists. - * - * @return - */ - public String getOutputContentClaimIdentifier() { - return outputContentClaimIdentifier; - } - - public void setOutputContentClaimIdentifier(String outputContentClaimIdentifier) { - this.outputContentClaimIdentifier = outputContentClaimIdentifier; - } - - /** - * Returns the offset into the the output Content Claim where the FlowFile's - * content begins, or <code>null</code> if no Content Claim exists. - * - * @return - */ - public Long getOutputContentClaimOffset() { - return outputContentClaimOffset; - } - - public void setOutputContentClaimOffset(Long outputContentClaimOffset) { - this.outputContentClaimOffset = outputContentClaimOffset; - } - - /** - * Returns the formatted file size of the input content claim. - * - * @return - */ - public String getOutputContentClaimFileSize() { - return outputContentClaimFileSize; - } - - public void setOutputContentClaimFileSize(String outputContentClaimFileSize) { - this.outputContentClaimFileSize = outputContentClaimFileSize; - } - - /** - * Returns the number of bytes of the input content claim. - * - * @return - */ - public Long getOutputContentClaimFileSizeBytes() { - return outputContentClaimFileSizeBytes; - } - - public void setOutputContentClaimFileSizeBytes(Long outputContentClaimFileSizeBytes) { - this.outputContentClaimFileSizeBytes = outputContentClaimFileSizeBytes; - } - - /** - * Returns whether or not the input content is still available. - * - * @return - */ - public Boolean getInputContentAvailable() { - return inputContentAvailable; - } - - public void setInputContentAvailable(Boolean inputContentAvailable) { - this.inputContentAvailable = inputContentAvailable; - } - - /** - * Returns the Section in which the input Content Claim lives, or - * <code>null</code> if no Content Claim exists. - * - * @return - */ - public String getInputContentClaimSection() { - return inputContentClaimSection; - } - - public void setInputContentClaimSection(String inputContentClaimSection) { - this.inputContentClaimSection = inputContentClaimSection; - } - - /** - * Returns the Container in which the input Content Claim lives, or - * <code>null</code> if no Content Claim exists. - * - * @return - */ - public String getInputContentClaimContainer() { - return inputContentClaimContainer; - } - - public void setInputContentClaimContainer(String inputContentClaimContainer) { - this.inputContentClaimContainer = inputContentClaimContainer; - } - - /** - * Returns the Identifier of the input Content Claim, or <code>null</code> - * if no Content Claim exists. - * - * @return - */ - public String getInputContentClaimIdentifier() { - return inputContentClaimIdentifier; - } - - public void setInputContentClaimIdentifier(String inputContentClaimIdentifier) { - this.inputContentClaimIdentifier = inputContentClaimIdentifier; - } - - /** - * Returns the offset into the the input Content Claim where the FlowFile's - * content begins, or <code>null</code> if no Content Claim exists. - * - * @return - */ - public Long getInputContentClaimOffset() { - return inputContentClaimOffset; - } - - public void setInputContentClaimOffset(Long inputContentClaimOffset) { - this.inputContentClaimOffset = inputContentClaimOffset; - } - - /** - * Returns the formatted file size of the input content claim. - * - * @return - */ - public String getInputContentClaimFileSize() { - return inputContentClaimFileSize; - } - - public void setInputContentClaimFileSize(String inputContentClaimFileSize) { - this.inputContentClaimFileSize = inputContentClaimFileSize; - } - - /** - * Returns the number of bytes of the input content claim. - * - * @return - */ - public Long getInputContentClaimFileSizeBytes() { - return inputContentClaimFileSizeBytes; - } - - public void setInputContentClaimFileSizeBytes(Long inputContentClaimFileSizeBytes) { - this.inputContentClaimFileSizeBytes = inputContentClaimFileSizeBytes; - } - - /** - * Returns whether or not replay is available. - * - * @return - */ - public Boolean getReplayAvailable() { - return replayAvailable; - } - - public void setReplayAvailable(Boolean replayAvailable) { - this.replayAvailable = replayAvailable; - } - - /** - * Returns the explanation as to why replay is unavailable. - * - * @return - */ - public String getReplayExplanation() { - return replayExplanation; - } - - public void setReplayExplanation(String replayExplanation) { - this.replayExplanation = replayExplanation; - } - - /** - * Returns identifier of the FlowFile Queue / Connection from which the - * FlowFile was pulled to generate this event, or <code>null</code> if - * either the queue is unknown or the FlowFile was created by this event. - * - * @return - */ - public String getSourceConnectionIdentifier() { - return sourceConnectionIdentifier; - } - - public void setSourceConnectionIdentifier(String sourceConnectionIdentifier) { - this.sourceConnectionIdentifier = sourceConnectionIdentifier; - } -}
http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceOptionsDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceOptionsDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceOptionsDTO.java deleted file mode 100644 index 7f939b9..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceOptionsDTO.java +++ /dev/null @@ -1,43 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.provenance; - -import java.util.List; -import javax.xml.bind.annotation.XmlType; - -/** - * A provenance search options. - */ -@XmlType(name = "provenanceOptions") -public class ProvenanceOptionsDTO { - - private List<ProvenanceSearchableFieldDTO> searchableFields; - - /** - * The available searchable fields for this NiFi instance. - * - * @return - */ - public List<ProvenanceSearchableFieldDTO> getSearchableFields() { - return searchableFields; - } - - public void setSearchableFields(List<ProvenanceSearchableFieldDTO> searchableFields) { - this.searchableFields = searchableFields; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceRequestDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceRequestDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceRequestDTO.java deleted file mode 100644 index e9e5453..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceRequestDTO.java +++ /dev/null @@ -1,118 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.provenance; - -import java.util.Date; -import java.util.Map; - -import javax.xml.bind.annotation.XmlType; -import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter; -import org.apache.nifi.web.api.dto.util.DateTimeAdapter; - -/** - * A request for provenance. - */ -@XmlType(name = "provenanceRequest") -public class ProvenanceRequestDTO { - - private Map<String, String> searchTerms; - private Date startDate; - private Date endDate; - private String minimumFileSize; - private String maximumFileSize; - private Integer maxResults; - - /** - * Returns the search terms to use for this search - * - * @return - */ - public Map<String, String> getSearchTerms() { - return searchTerms; - } - - public void setSearchTerms(final Map<String, String> searchTerms) { - this.searchTerms = searchTerms; - } - - /** - * The earliest event time to include in the query - * - * @return - */ - @XmlJavaTypeAdapter(DateTimeAdapter.class) - public Date getStartDate() { - return startDate; - } - - public void setStartDate(Date startDate) { - this.startDate = startDate; - } - - /** - * The latest event time to include in the query - * - * @return - */ - @XmlJavaTypeAdapter(DateTimeAdapter.class) - public Date getEndDate() { - return endDate; - } - - public void setEndDate(Date endDate) { - this.endDate = endDate; - } - - /** - * The minimum file size to include in the query. - * - * @return - */ - public String getMinimumFileSize() { - return minimumFileSize; - } - - public void setMinimumFileSize(String minimumFileSize) { - this.minimumFileSize = minimumFileSize; - } - - /** - * The maximum file size to include in the query. - * - * @return - */ - public String getMaximumFileSize() { - return maximumFileSize; - } - - public void setMaximumFileSize(String maximumFileSize) { - this.maximumFileSize = maximumFileSize; - } - - /** - * The number of max results. - * - * @return - */ - public Integer getMaxResults() { - return maxResults; - } - - public void setMaxResults(Integer maxResults) { - this.maxResults = maxResults; - } -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceResultsDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceResultsDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceResultsDTO.java deleted file mode 100644 index d6ea8a0..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceResultsDTO.java +++ /dev/null @@ -1,136 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.provenance; - -import org.apache.nifi.web.api.dto.util.DateTimeAdapter; -import org.apache.nifi.web.api.dto.util.TimeAdapter; - -import javax.xml.bind.annotation.XmlType; -import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter; -import java.util.Date; -import java.util.List; -import java.util.Set; - -/** - * Results of a provenance request. - */ -@XmlType(name = "provenanceResults") -public class ProvenanceResultsDTO { - - private List<ProvenanceEventDTO> provenanceEvents; - private String total; - private Long totalCount; - private Date generated; - private Date oldestEvent; - private Integer timeOffset; - - private Set<String> errors; - - /** - * Any error messages. - * - * @return - */ - public Set<String> getErrors() { - return errors; - } - - public void setErrors(Set<String> errors) { - this.errors = errors; - } - - /** - * The provenance events that matched the search criteria. - * - * @return - */ - public List<ProvenanceEventDTO> getProvenanceEvents() { - return provenanceEvents; - } - - public void setProvenanceEvents(List<ProvenanceEventDTO> provenanceEvents) { - this.provenanceEvents = provenanceEvents; - } - - /** - * The total number of results formatted. - * - * @return - */ - public String getTotal() { - return total; - } - - public void setTotal(String total) { - this.total = total; - } - - /** - * The total number of results. - * - * @return - */ - public Long getTotalCount() { - return totalCount; - } - - public void setTotalCount(Long totalCount) { - this.totalCount = totalCount; - } - - /** - * When the search was performed. - * - * @return - */ - @XmlJavaTypeAdapter(TimeAdapter.class) - public Date getGenerated() { - return generated; - } - - public void setGenerated(Date generated) { - this.generated = generated; - } - - /** - * The oldest event available in the provenance repository. - * - * @return - */ - @XmlJavaTypeAdapter(DateTimeAdapter.class) - public Date getOldestEvent() { - return oldestEvent; - } - - public void setOldestEvent(Date oldestEvent) { - this.oldestEvent = oldestEvent; - } - - /** - * The time offset on the server thats used for event time. - * - * @return - */ - public Integer getTimeOffset() { - return timeOffset; - } - - public void setTimeOffset(Integer timeOffset) { - this.timeOffset = timeOffset; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceSearchableFieldDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceSearchableFieldDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceSearchableFieldDTO.java deleted file mode 100644 index af89f97..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceSearchableFieldDTO.java +++ /dev/null @@ -1,84 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.provenance; - -import javax.xml.bind.annotation.XmlType; - -/** - * A searchable field for provenance queries. - */ -@XmlType(name = "provenanceSearchableField") -public class ProvenanceSearchableFieldDTO { - - private String id; - private String field; - private String label; - private String type; - - /** - * The id of this searchable field. - * - * @return - */ - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id; - } - - /** - * The field. - * - * @return - */ - public String getField() { - return field; - } - - public void setField(String field) { - this.field = field; - } - - /** - * The label for this field. - * - * @return - */ - public String getLabel() { - return label; - } - - public void setLabel(String label) { - this.label = label; - } - - /** - * The type for this field. - * - * @return - */ - public String getType() { - return type; - } - - public void setType(String type) { - this.type = type; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageDTO.java deleted file mode 100644 index 745105e..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageDTO.java +++ /dev/null @@ -1,161 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.provenance.lineage; - -import java.util.Date; -import javax.xml.bind.annotation.XmlType; -import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter; -import org.apache.nifi.web.api.dto.util.TimestampAdapter; - -/** - * Represents the lineage for a flowfile. - */ -@XmlType(name = "lineage") -public class LineageDTO { - - private String id; - private String uri; - private String clusterNodeId; - - private Date submissionTime; - private Date expiration; - private Integer percentCompleted; - private Boolean finished; - - private LineageRequestDTO request; - private LineageResultsDTO results; - - /** - * The id of this lineage. - * - * @return - */ - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id; - } - - /** - * The uri for this lineage. - * - * @return - */ - public String getUri() { - return uri; - } - - public void setUri(String uri) { - this.uri = uri; - } - - /** - * The id of the node in the cluster where this lineage originated. - * - * @return - */ - public String getClusterNodeId() { - return clusterNodeId; - } - - public void setClusterNodeId(String clusterNodeId) { - this.clusterNodeId = clusterNodeId; - } - - /** - * The submission time for this lineage. - * - * @return - */ - @XmlJavaTypeAdapter(TimestampAdapter.class) - public Date getSubmissionTime() { - return submissionTime; - } - - public void setSubmissionTime(Date submissionTime) { - this.submissionTime = submissionTime; - } - - /** - * The expiration of this lineage. - * - * @return - */ - @XmlJavaTypeAdapter(TimestampAdapter.class) - public Date getExpiration() { - return expiration; - } - - public void setExpiration(Date expiration) { - this.expiration = expiration; - } - - /** - * Percent completed for this result. - * - * @return - */ - public Integer getPercentCompleted() { - return percentCompleted; - } - - public void setPercentCompleted(Integer percentCompleted) { - this.percentCompleted = percentCompleted; - } - - /** - * Whether or not the request is finished running. - * - * @return - */ - public Boolean getFinished() { - return finished; - } - - public void setFinished(Boolean finished) { - this.finished = finished; - } - - /** - * The lineage request. - * - * @return - */ - public LineageRequestDTO getRequest() { - return request; - } - - public void setRequest(LineageRequestDTO request) { - this.request = request; - } - - /** - * The results of this lineage. - * - * @return - */ - public LineageResultsDTO getResults() { - return results; - } - - public void setResults(LineageResultsDTO results) { - this.results = results; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageRequestDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageRequestDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageRequestDTO.java deleted file mode 100644 index 23cf892..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageRequestDTO.java +++ /dev/null @@ -1,88 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.provenance.lineage; - -import javax.xml.bind.annotation.XmlEnum; -import javax.xml.bind.annotation.XmlType; - -/** - * Represents the request for lineage for a flowfile. - */ -@XmlType(name = "lineageRequest") -public class LineageRequestDTO { - - /** - * The type of this lineage request. - */ - @XmlType(name = "lineageRequestType") - @XmlEnum - public enum LineageRequestType { - - PARENTS, - CHILDREN, - FLOWFILE; - }; - - private Long eventId; - private LineageRequestType lineageRequestType; - - private String uuid; - - /** - * The event id that was used to generate this lineage. - * - * @return - */ - public Long getEventId() { - return eventId; - } - - public void setEventId(Long eventId) { - this.eventId = eventId; - } - - /** - * The type of lineage request. Either 'PARENTS', 'CHILDREN', or 'FLOWFILE'. - * PARENTS will return the lineage for the flowfiles that are parents of the - * specified event. CHILDREN will return the lineage of for the flowfiles - * that are children of the specified event. FLOWFILE will return the - * lineage for the specified flowfile. - * - * @return - */ - public LineageRequestType getLineageRequestType() { - return lineageRequestType; - } - - public void setLineageRequestType(LineageRequestType lineageRequestType) { - this.lineageRequestType = lineageRequestType; - } - - /** - * The uuid that was used to generate this lineage. - * - * @return - */ - public String getUuid() { - return uuid; - } - - public void setUuid(String uuid) { - this.uuid = uuid; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageResultsDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageResultsDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageResultsDTO.java deleted file mode 100644 index 77b6e7a..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageResultsDTO.java +++ /dev/null @@ -1,73 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.provenance.lineage; - -import java.util.List; -import java.util.Set; -import javax.xml.bind.annotation.XmlType; - -/** - * Represents the lineage results. - */ -@XmlType(name = "lineage") -public class LineageResultsDTO { - - private Set<String> errors; - - private List<ProvenanceNodeDTO> nodes; - private List<ProvenanceLinkDTO> links; - - /** - * Any error messages. - * - * @return - */ - public Set<String> getErrors() { - return errors; - } - - public void setErrors(Set<String> errors) { - this.errors = errors; - } - - /** - * The nodes. - * - * @return - */ - public List<ProvenanceNodeDTO> getNodes() { - return nodes; - } - - public void setNodes(List<ProvenanceNodeDTO> nodes) { - this.nodes = nodes; - } - - /** - * The links. - * - * @return - */ - public List<ProvenanceLinkDTO> getLinks() { - return links; - } - - public void setLinks(List<ProvenanceLinkDTO> links) { - this.links = links; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/ProvenanceLinkDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/ProvenanceLinkDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/ProvenanceLinkDTO.java deleted file mode 100644 index f3bbcef..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/ProvenanceLinkDTO.java +++ /dev/null @@ -1,101 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.provenance.lineage; - -import java.util.Date; -import javax.xml.bind.annotation.XmlType; -import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter; -import org.apache.nifi.web.api.dto.util.TimestampAdapter; - -/** - * A link between an event or flowfile within a provenance lineage. - */ -@XmlType(name = "provenanceLink") -public class ProvenanceLinkDTO { - - private String sourceId; - private String targetId; - private String flowFileUuid; - private Date timestamp; - private Long millis; - - /** - * The source node id. - * - * @return - */ - public String getSourceId() { - return sourceId; - } - - public void setSourceId(String sourceId) { - this.sourceId = sourceId; - } - - /** - * The target node id. - * - * @return - */ - public String getTargetId() { - return targetId; - } - - public void setTargetId(String targetId) { - this.targetId = targetId; - } - - /** - * The flowfile uuid that traversed this link. - * - * @return - */ - public String getFlowFileUuid() { - return flowFileUuid; - } - - public void setFlowFileUuid(String flowFileUuid) { - this.flowFileUuid = flowFileUuid; - } - - /** - * The timestamp of this link (based on the destination). - * - * @return - */ - @XmlJavaTypeAdapter(TimestampAdapter.class) - public Date getTimestamp() { - return timestamp; - } - - public void setTimestamp(Date timestamp) { - this.timestamp = timestamp; - } - - /** - * The number of millis since epoch. - * - * @return - */ - public Long getMillis() { - return millis; - } - - public void setMillis(Long millis) { - this.millis = millis; - } -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/ProvenanceNodeDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/ProvenanceNodeDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/ProvenanceNodeDTO.java deleted file mode 100644 index c15c598..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/ProvenanceNodeDTO.java +++ /dev/null @@ -1,162 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.provenance.lineage; - -import java.util.Date; -import java.util.List; - -import javax.xml.bind.annotation.XmlType; -import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter; - -import org.apache.nifi.web.api.dto.util.TimestampAdapter; - -/** - * A node within a provenance lineage. May represent either an event or a - * flowfile. - */ -@XmlType(name = "provenanceNode") -public class ProvenanceNodeDTO { - - private String id; - private String flowFileUuid; - private List<String> parentUuids; - private List<String> childUuids; - private String clusterNodeIdentifier; - private String type; - private String eventType; - private Long millis; - private Date timestamp; - - /** - * The id of the node. - * - * @return - */ - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id; - } - - /** - * The flowfile uuid for this provenance event. - * - * @return - */ - public String getFlowFileUuid() { - return flowFileUuid; - } - - public void setFlowFileUuid(String flowFileUuid) { - this.flowFileUuid = flowFileUuid; - } - - /** - * The parent flowfile uuids for this provenance event. - * - * @return - */ - public List<String> getParentUuids() { - return parentUuids; - } - - public void setParentUuids(List<String> parentUuids) { - this.parentUuids = parentUuids; - } - - /** - * The child flowfile uuids for this provenance event. - * - * @return - */ - public List<String> getChildUuids() { - return childUuids; - } - - public void setChildUuids(List<String> childUuids) { - this.childUuids = childUuids; - } - - /** - * The node identifier that this event/flowfile originated from. - * - * @return - */ - public String getClusterNodeIdentifier() { - return clusterNodeIdentifier; - } - - public void setClusterNodeIdentifier(String clusterNodeIdentifier) { - this.clusterNodeIdentifier = clusterNodeIdentifier; - } - - /** - * The type of node. - * - * @return - */ - public String getType() { - return type; - } - - public void setType(String type) { - this.type = type; - } - - /** - * If this is an event node, this is the type of event. - * - * @return - */ - public String getEventType() { - return eventType; - } - - public void setEventType(String eventType) { - this.eventType = eventType; - } - - /** - * The timestamp of this node. - * - * @return - */ - @XmlJavaTypeAdapter(TimestampAdapter.class) - public Date getTimestamp() { - return timestamp; - } - - public void setTimestamp(Date timestamp) { - this.timestamp = timestamp; - } - - /** - * The number of millis since epoch. - * - * @return - */ - public Long getMillis() { - return millis; - } - - public void setMillis(Long millis) { - this.millis = millis; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/ComponentSearchResultDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/ComponentSearchResultDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/ComponentSearchResultDTO.java deleted file mode 100644 index 83d7a91..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/ComponentSearchResultDTO.java +++ /dev/null @@ -1,85 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.search; - -import java.util.List; -import javax.xml.bind.annotation.XmlType; - -/** - * The components that match a search performed on this NiFi. - */ -@XmlType(name = "componentSearchResult") -public class ComponentSearchResultDTO { - - private String id; - private String groupId; - private String name; - private List<String> matches; - - /** - * The id of the component that matched. - * - * @return - */ - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id; - } - - /** - * The group id of the component that matched. - * - * @return - */ - public String getGroupId() { - return groupId; - } - - public void setGroupId(String groupId) { - this.groupId = groupId; - } - - /** - * The name of the component that matched. - * - * @return - */ - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } - - /** - * What matched the search string for this component. - * - * @return - */ - public List<String> getMatches() { - return matches; - } - - public void setMatches(List<String> matches) { - this.matches = matches; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/NodeSearchResultDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/NodeSearchResultDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/NodeSearchResultDTO.java deleted file mode 100644 index 7c250ee..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/NodeSearchResultDTO.java +++ /dev/null @@ -1,56 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.search; - -import javax.xml.bind.annotation.XmlType; - -/** - * A search result for a matching node. - */ -@XmlType(name = "nodeSearchResult") -public class NodeSearchResultDTO { - - private String id; - private String address; - - /** - * The id of the node that was matched. - * - * @return - */ - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id; - } - - /** - * The address of the node that was matched. - * - * @return - */ - public String getAddress() { - return address; - } - - public void setAddress(String address) { - this.address = address; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/SearchResultsDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/SearchResultsDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/SearchResultsDTO.java deleted file mode 100644 index 212d4f2..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/SearchResultsDTO.java +++ /dev/null @@ -1,128 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.search; - -import java.util.ArrayList; -import java.util.List; -import javax.xml.bind.annotation.XmlType; - -/** - * The results of a search on this NiFi. - */ -@XmlType(name = "searchResults") -public class SearchResultsDTO { - - private List<ComponentSearchResultDTO> processorResults = new ArrayList<>(); - private List<ComponentSearchResultDTO> connectionResults = new ArrayList<>(); - private List<ComponentSearchResultDTO> processGroupResults = new ArrayList<>(); - private List<ComponentSearchResultDTO> inputPortResults = new ArrayList<>(); - private List<ComponentSearchResultDTO> outputPortResults = new ArrayList<>(); - private List<ComponentSearchResultDTO> remoteProcessGroupResults = new ArrayList<>(); - private List<ComponentSearchResultDTO> funnelResults = new ArrayList<>(); - - /** - * The processors that matched the search. - * - * @return - */ - public List<ComponentSearchResultDTO> getProcessorResults() { - return processorResults; - } - - public void setProcessorResults(List<ComponentSearchResultDTO> processorResults) { - this.processorResults = processorResults; - } - - /** - * The connections that matched the search. - * - * @return - */ - public List<ComponentSearchResultDTO> getConnectionResults() { - return connectionResults; - } - - public void setConnectionResults(List<ComponentSearchResultDTO> connectionResults) { - this.connectionResults = connectionResults; - } - - /** - * The process group that matched the search. - * - * @return - */ - public List<ComponentSearchResultDTO> getProcessGroupResults() { - return processGroupResults; - } - - public void setProcessGroupResults(List<ComponentSearchResultDTO> processGroupResults) { - this.processGroupResults = processGroupResults; - } - - /** - * The input ports that matched the search. - * - * @return - */ - public List<ComponentSearchResultDTO> getInputPortResults() { - return inputPortResults; - } - - /** - * The output ports that matched the search. - * - * @return - */ - public List<ComponentSearchResultDTO> getOutputPortResults() { - return outputPortResults; - } - - public void setInputPortResults(List<ComponentSearchResultDTO> inputPortResults) { - this.inputPortResults = inputPortResults; - } - - public void setOutputPortResults(List<ComponentSearchResultDTO> outputPortResults) { - this.outputPortResults = outputPortResults; - } - - /** - * The remote process groups that matched the search. - * - * @return - */ - public List<ComponentSearchResultDTO> getRemoteProcessGroupResults() { - return remoteProcessGroupResults; - } - - public void setRemoteProcessGroupResults(List<ComponentSearchResultDTO> remoteProcessGroupResults) { - this.remoteProcessGroupResults = remoteProcessGroupResults; - } - - /** - * The funnels that matched the search. - * - * @return - */ - public List<ComponentSearchResultDTO> getFunnelResults() { - return funnelResults; - } - - public void setFunnelResults(List<ComponentSearchResultDTO> funnelResults) { - this.funnelResults = funnelResults; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/UserGroupSearchResultDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/UserGroupSearchResultDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/UserGroupSearchResultDTO.java deleted file mode 100644 index ab5636d..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/UserGroupSearchResultDTO.java +++ /dev/null @@ -1,42 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.search; - -import javax.xml.bind.annotation.XmlType; - -/** - * A search result for a matching user group. - */ -@XmlType(name = "userGroupSearchResult") -public class UserGroupSearchResultDTO { - - private String group; - - /** - * The name of the group that matched. - * - * @return - */ - public String getGroup() { - return group; - } - - public void setGroup(String group) { - this.group = group; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/UserSearchResultDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/UserSearchResultDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/UserSearchResultDTO.java deleted file mode 100644 index 9402eeb..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/UserSearchResultDTO.java +++ /dev/null @@ -1,56 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.search; - -import javax.xml.bind.annotation.XmlType; - -/** - * A search result for a matching user. - */ -@XmlType(name = "userSearchResult") -public class UserSearchResultDTO { - - private String userName; - private String userDn; - - /** - * The dn of the user that matched. - * - * @return - */ - public String getUserDn() { - return userDn; - } - - public void setUserDn(String userDn) { - this.userDn = userDn; - } - - /** - * The username of user that matched. - * - * @return - */ - public String getUserName() { - return userName; - } - - public void setUserName(String userName) { - this.userName = userName; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterConnectionStatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterConnectionStatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterConnectionStatusDTO.java deleted file mode 100644 index f0e11d6..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterConnectionStatusDTO.java +++ /dev/null @@ -1,89 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.status; - -import java.util.Collection; -import java.util.Date; -import javax.xml.bind.annotation.XmlType; -import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter; -import org.apache.nifi.web.api.dto.util.TimeAdapter; - -/** - * DTO for serializing the a connection's status across the cluster. - */ -@XmlType(name = "clusterConnectionStatus") -public class ClusterConnectionStatusDTO { - - private Collection<NodeConnectionStatusDTO> nodeConnectionStatus; - private Date statsLastRefreshed; - private String connectionId; - private String connectionName; - - /** - * The time the status were last refreshed. - * - * @return - */ - @XmlJavaTypeAdapter(TimeAdapter.class) - public Date getStatsLastRefreshed() { - return statsLastRefreshed; - } - - public void setStatsLastRefreshed(Date statsLastRefreshed) { - this.statsLastRefreshed = statsLastRefreshed; - } - - /** - * The connection id. - * - * @return - */ - public String getConnectionId() { - return connectionId; - } - - public void setConnectionId(String connectionId) { - this.connectionId = connectionId; - } - - /** - * The connection name. - * - * @return - */ - public String getConnectionName() { - return connectionName; - } - - public void setConnectionName(String connectionName) { - this.connectionName = connectionName; - } - - /** - * Collection of node connection status DTO. - * - * @return The collection of node connection status DTO - */ - public Collection<NodeConnectionStatusDTO> getNodeConnectionStatus() { - return nodeConnectionStatus; - } - - public void setNodeConnectionStatus(Collection<NodeConnectionStatusDTO> nodeConnectionStatus) { - this.nodeConnectionStatus = nodeConnectionStatus; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterPortStatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterPortStatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterPortStatusDTO.java deleted file mode 100644 index 4d7fa4d..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterPortStatusDTO.java +++ /dev/null @@ -1,89 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.status; - -import java.util.Collection; -import java.util.Date; -import javax.xml.bind.annotation.XmlType; -import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter; -import org.apache.nifi.web.api.dto.util.TimeAdapter; - -/** - * DTO for serializing the a port's status across the cluster. - */ -@XmlType(name = "clusterPortStatus") -public class ClusterPortStatusDTO { - - private Collection<NodePortStatusDTO> nodePortStatus; - private Date statsLastRefreshed; - private String portId; - private String portName; - - /** - * The time the status was last refreshed. - * - * @return the time the status were last refreshed - */ - @XmlJavaTypeAdapter(TimeAdapter.class) - public Date getStatsLastRefreshed() { - return statsLastRefreshed; - } - - public void setStatsLastRefreshed(Date statsLastRefreshed) { - this.statsLastRefreshed = statsLastRefreshed; - } - - /** - * The port status from each node in the cluster. - * - * @return - */ - public Collection<NodePortStatusDTO> getNodePortStatus() { - return nodePortStatus; - } - - public void setNodePortStatus(Collection<NodePortStatusDTO> nodePortStatus) { - this.nodePortStatus = nodePortStatus; - } - - /** - * The port id. - * - * @return - */ - public String getPortId() { - return portId; - } - - public void setPortId(String portId) { - this.portId = portId; - } - - /** - * The port name. - * - * @return - */ - public String getPortName() { - return portName; - } - - public void setPortName(String portName) { - this.portName = portName; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterProcessorStatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterProcessorStatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterProcessorStatusDTO.java deleted file mode 100644 index b9f45f2..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterProcessorStatusDTO.java +++ /dev/null @@ -1,117 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.status; - -import java.util.Collection; -import java.util.Date; -import javax.xml.bind.annotation.XmlType; -import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter; -import org.apache.nifi.web.api.dto.util.TimeAdapter; - -/** - * DTO for serializing the a processor's status across the cluster. - */ -@XmlType(name = "clusterProcessorStatus") -public class ClusterProcessorStatusDTO { - - private Collection<NodeProcessorStatusDTO> nodeProcessorStatus; - private Date statsLastRefreshed; - private String processorId; - private String processorName; - private String processorType; - private String processorRunStatus; - - /** - * The time the status were last refreshed. - * - * @return - */ - @XmlJavaTypeAdapter(TimeAdapter.class) - public Date getStatsLastRefreshed() { - return statsLastRefreshed; - } - - public void setStatsLastRefreshed(Date statsLastRefreshed) { - this.statsLastRefreshed = statsLastRefreshed; - } - - /** - * The processor id. - * - * @return - */ - public String getProcessorId() { - return processorId; - } - - public void setProcessorId(String processorId) { - this.processorId = processorId; - } - - /** - * The processor name. - * - * @return - */ - public String getProcessorName() { - return processorName; - } - - public void setProcessorName(String processorName) { - this.processorName = processorName; - } - - /** - * The processor type. - * - * @return - */ - public String getProcessorType() { - return processorType; - } - - public void setProcessorType(String processorType) { - this.processorType = processorType; - } - - /** - * The processor run status. - * - * @return - */ - public String getProcessorRunStatus() { - return processorRunStatus; - } - - public void setProcessorRunStatus(String runStatus) { - this.processorRunStatus = runStatus; - } - - /** - * Collection of node processor status DTO. - * - * @return The collection of node processor status DTO - */ - public Collection<NodeProcessorStatusDTO> getNodeProcessorStatus() { - return nodeProcessorStatus; - } - - public void setNodeProcessorStatus(Collection<NodeProcessorStatusDTO> nodeProcessorStatus) { - this.nodeProcessorStatus = nodeProcessorStatus; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterRemoteProcessGroupStatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterRemoteProcessGroupStatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterRemoteProcessGroupStatusDTO.java deleted file mode 100644 index d6b26d4..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterRemoteProcessGroupStatusDTO.java +++ /dev/null @@ -1,89 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.status; - -import java.util.Collection; -import java.util.Date; -import javax.xml.bind.annotation.XmlType; -import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter; -import org.apache.nifi.web.api.dto.util.TimeAdapter; - -/** - * DTO for serializing the a remote process group's status across the cluster. - */ -@XmlType(name = "clusterRemoteProcessGroupStatus") -public class ClusterRemoteProcessGroupStatusDTO { - - private Collection<NodeRemoteProcessGroupStatusDTO> nodeRemoteProcessGroupStatus; - private Date statsLastRefreshed; - private String remoteProcessGroupId; - private String remoteProcessGroupName; - - /** - * The time the status was last refreshed. - * - * @return the time the status were last refreshed - */ - @XmlJavaTypeAdapter(TimeAdapter.class) - public Date getStatsLastRefreshed() { - return statsLastRefreshed; - } - - public void setStatsLastRefreshed(Date statsLastRefreshed) { - this.statsLastRefreshed = statsLastRefreshed; - } - - /** - * The remote process group status from each node in the cluster. - * - * @return - */ - public Collection<NodeRemoteProcessGroupStatusDTO> getNodeRemoteProcessGroupStatus() { - return nodeRemoteProcessGroupStatus; - } - - public void setNodeRemoteProcessGroupStatus(Collection<NodeRemoteProcessGroupStatusDTO> nodeRemoteProcessGroupStatus) { - this.nodeRemoteProcessGroupStatus = nodeRemoteProcessGroupStatus; - } - - /** - * The remote process group id. - * - * @return - */ - public String getRemoteProcessGroupId() { - return remoteProcessGroupId; - } - - public void setRemoteProcessGroupId(String remoteProcessGroupId) { - this.remoteProcessGroupId = remoteProcessGroupId; - } - - /** - * The remote process group name. - * - * @return - */ - public String getRemoteProcessGroupName() { - return remoteProcessGroupName; - } - - public void setRemoteProcessGroupName(String remoteProcessGroupName) { - this.remoteProcessGroupName = remoteProcessGroupName; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterStatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterStatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterStatusDTO.java deleted file mode 100644 index d833991..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterStatusDTO.java +++ /dev/null @@ -1,44 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.status; - -import java.util.Collection; - -import javax.xml.bind.annotation.XmlType; - -/** - * DTO for serializing the controller status. - */ -@XmlType(name = "clusterStatus") -public class ClusterStatusDTO { - - private Collection<NodeStatusDTO> nodeStatus; - - /** - * The collection of the node status DTOs. - * - * @return - */ - public Collection<NodeStatusDTO> getNodeStatus() { - return nodeStatus; - } - - public void setNodeStatus(Collection<NodeStatusDTO> nodeStatus) { - this.nodeStatus = nodeStatus; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterStatusHistoryDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterStatusHistoryDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterStatusHistoryDTO.java deleted file mode 100644 index 31a9948..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterStatusHistoryDTO.java +++ /dev/null @@ -1,75 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.nifi.web.api.dto.status; - -import java.util.Collection; -import java.util.Date; -import javax.xml.bind.annotation.XmlType; -import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter; -import org.apache.nifi.web.api.dto.util.TimeAdapter; - -/** - * DTO for serializing the a status history across the cluster. - */ -@XmlType(name = "clusterStatusHistory") -public class ClusterStatusHistoryDTO { - - private Collection<NodeStatusHistoryDTO> nodeStatusHistory; - private StatusHistoryDTO clusterStatusHistory; - private Date generated; - - /** - * When this status history was generated. - * - * @return - */ - @XmlJavaTypeAdapter(TimeAdapter.class) - public Date getGenerated() { - return generated; - } - - public void setGenerated(Date generated) { - this.generated = generated; - } - - /** - * The status history from each node in the cluster. - * - * @return - */ - public Collection<NodeStatusHistoryDTO> getNodeStatusHistory() { - return nodeStatusHistory; - } - - public void setNodeStatusHistory(Collection<NodeStatusHistoryDTO> nodeStatusHistory) { - this.nodeStatusHistory = nodeStatusHistory; - } - - /** - * The status history for this component across the entire cluster. - * - * @return - */ - public StatusHistoryDTO getClusterStatusHistory() { - return clusterStatusHistory; - } - - public void setClusterStatusHistory(StatusHistoryDTO clusterStatusHistory) { - this.clusterStatusHistory = clusterStatusHistory; - } - -}