http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceOptionsDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceOptionsDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceRequestDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceRequestDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceResultsDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceResultsDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceSearchableFieldDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/ProvenanceSearchableFieldDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageRequestDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageRequestDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageResultsDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/LineageResultsDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/ProvenanceLinkDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/ProvenanceLinkDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/ProvenanceNodeDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/provenance/lineage/ProvenanceNodeDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/ComponentSearchResultDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/ComponentSearchResultDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/NodeSearchResultDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/NodeSearchResultDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/SearchResultsDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/SearchResultsDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/UserGroupSearchResultDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/UserGroupSearchResultDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/UserSearchResultDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/search/UserSearchResultDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterConnectionStatusDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterConnectionStatusDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterPortStatusDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterPortStatusDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterProcessorStatusDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterProcessorStatusDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterRemoteProcessGroupStatusDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterRemoteProcessGroupStatusDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterStatusDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterStatusDTO.java b/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/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/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterStatusHistoryDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ClusterStatusHistoryDTO.java b/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/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; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ConnectionStatusDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ConnectionStatusDTO.java b/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ConnectionStatusDTO.java deleted file mode 100644 index 387cce5..0000000 --- a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ConnectionStatusDTO.java +++ /dev/null @@ -1,198 +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 javax.xml.bind.annotation.XmlType; - -/** - * DTO for serializing the status of a connection. - */ -@XmlType(name = "connectionStatus") -public class ConnectionStatusDTO { - - private String id; - private String groupId; - private String name; - private String input; - private String queuedCount; - private String queuedSize; - private String queued; - private String output; - - private String sourceId; - private String sourceName; - private String destinationId; - private String destinationName; - - /* getters / setters */ - /** - * The id for the connection. - * - * @return The connection id - */ - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id; - } - - /** - * The ID of the Process Group to which this processor belongs. - * - * @return the ID of the Process Group to which this processor belongs. - */ - public String getGroupId() { - return groupId; - } - - public void setGroupId(final String groupId) { - this.groupId = groupId; - } - - /** - * The name of this connection. - * - * @return - */ - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } - - /** - * The total count of flow files that are queued. - * - * @return - */ - public String getQueuedCount() { - return queuedCount; - } - - public void setQueuedCount(String queuedCount) { - this.queuedCount = queuedCount; - } - - /** - * The total size of flow files that are queued. - * - * @return - */ - public String getQueuedSize() { - return queuedSize; - } - - public void setQueuedSize(String queuedSize) { - this.queuedSize = queuedSize; - } - - /** - * The total count and size of flow files that are queued. - * - * @return The total count and size of queued flow files - */ - public String getQueued() { - return queued; - } - - public void setQueued(String queued) { - this.queued = queued; - } - - /** - * The id of the source of this connection. - * - * @return - */ - public String getSourceId() { - return sourceId; - } - - public void setSourceId(String sourceId) { - this.sourceId = sourceId; - } - - /** - * The name of the source of this connection. - * - * @return - */ - public String getSourceName() { - return sourceName; - } - - public void setSourceName(String sourceName) { - this.sourceName = sourceName; - } - - /** - * The id of the destination of this connection. - * - * @return - */ - public String getDestinationId() { - return destinationId; - } - - public void setDestinationId(String destinationId) { - this.destinationId = destinationId; - } - - /** - * The name of the destination of this connection. - * - * @return - */ - public String getDestinationName() { - return destinationName; - } - - public void setDestinationName(String destinationName) { - this.destinationName = destinationName; - } - - /** - * The input for this connection. - * - * @return - */ - public String getInput() { - return input; - } - - public void setInput(String input) { - this.input = input; - } - - /** - * The output for this connection. - * - * @return - */ - public String getOutput() { - return output; - } - - public void setOutput(String output) { - this.output = output; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ControllerStatusDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ControllerStatusDTO.java b/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ControllerStatusDTO.java deleted file mode 100644 index 9e063e4..0000000 --- a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ControllerStatusDTO.java +++ /dev/null @@ -1,187 +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.List; -import javax.xml.bind.annotation.XmlType; -import org.apache.nifi.web.api.dto.BulletinDTO; - -/** - * The status of this NiFi controller. - */ -@XmlType(name = "controllerStatus") -public class ControllerStatusDTO { - - private Integer activeThreadCount; - private String queued; - private String connectedNodes; - private Boolean hasPendingAccounts; - - private Integer runningCount; - private Integer stoppedCount; - private Integer invalidCount; - private Integer disabledCount; - private Integer activeRemotePortCount; - private Integer inactiveRemotePortCount; - - private List<BulletinDTO> bulletins; - - /** - * The active thread count. - * - * @return The active thread count - */ - public Integer getActiveThreadCount() { - return activeThreadCount; - } - - public void setActiveThreadCount(Integer activeThreadCount) { - this.activeThreadCount = activeThreadCount; - } - - /** - * The queue for the controller. - * - * @return - */ - public String getQueued() { - return queued; - } - - public void setQueued(String queued) { - this.queued = queued; - } - - /** - * Used in clustering, will report the number of nodes connected vs the - * number of nodes in the cluster. - * - * @return - */ - public String getConnectedNodes() { - return connectedNodes; - } - - public void setConnectedNodes(String connectedNodes) { - this.connectedNodes = connectedNodes; - } - - /** - * System bulletins to be reported to the user. - * - * @return - */ - public List<BulletinDTO> getBulletins() { - return bulletins; - } - - public void setBulletins(List<BulletinDTO> bulletins) { - this.bulletins = bulletins; - } - - /** - * Whether or not there are pending user requests. - * - * @return - */ - public Boolean getHasPendingAccounts() { - return hasPendingAccounts; - } - - public void setHasPendingAccounts(Boolean hasPendingAccounts) { - this.hasPendingAccounts = hasPendingAccounts; - } - - /** - * The number of running components in this controller. - * - * @return - */ - public Integer getRunningCount() { - return runningCount; - } - - public void setRunningCount(Integer runningCount) { - this.runningCount = runningCount; - } - - /** - * The number of stopped components in this controller. - * - * @return - */ - public Integer getStoppedCount() { - return stoppedCount; - } - - public void setStoppedCount(Integer stoppedCount) { - this.stoppedCount = stoppedCount; - } - - /** - * The number of invalid components in this controller. - * - * @return - */ - public Integer getInvalidCount() { - return invalidCount; - } - - public void setInvalidCount(Integer invalidCount) { - this.invalidCount = invalidCount; - } - - /** - * The number of disabled components in this controller. - * - * @return - */ - public Integer getDisabledCount() { - return disabledCount; - } - - public void setDisabledCount(Integer disabledCount) { - this.disabledCount = disabledCount; - } - - /** - * The number of active remote ports in this controller. - * - * @return - */ - public Integer getActiveRemotePortCount() { - return activeRemotePortCount; - } - - public void setActiveRemotePortCount(Integer activeRemotePortCount) { - this.activeRemotePortCount = activeRemotePortCount; - } - - /** - * The number of inactive remote ports in this controller. - * - * @return - */ - public Integer getInactiveRemotePortCount() { - return inactiveRemotePortCount; - } - - public void setInactiveRemotePortCount(Integer inactiveRemotePortCount) { - this.inactiveRemotePortCount = inactiveRemotePortCount; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeConnectionStatusDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeConnectionStatusDTO.java b/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeConnectionStatusDTO.java deleted file mode 100644 index f7cba44..0000000 --- a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeConnectionStatusDTO.java +++ /dev/null @@ -1,57 +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 javax.xml.bind.annotation.XmlType; -import org.apache.nifi.web.api.dto.NodeDTO; - -/** - * DTO for serializing the connection status for a particular node. - */ -@XmlType(name = "nodeConnectionStatus") -public class NodeConnectionStatusDTO { - - private NodeDTO node; - private ConnectionStatusDTO connectionStatus; - - /** - * The node. - * - * @return - */ - public NodeDTO getNode() { - return node; - } - - public void setNode(NodeDTO node) { - this.node = node; - } - - /** - * The connection's status. - * - * @return - */ - public ConnectionStatusDTO getConnectionStatus() { - return connectionStatus; - } - - public void setConnectionStatus(ConnectionStatusDTO connectionStatus) { - this.connectionStatus = connectionStatus; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodePortStatusDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodePortStatusDTO.java b/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodePortStatusDTO.java deleted file mode 100644 index 93d89ac..0000000 --- a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodePortStatusDTO.java +++ /dev/null @@ -1,57 +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 javax.xml.bind.annotation.XmlType; -import org.apache.nifi.web.api.dto.NodeDTO; - -/** - * DTO for serializing the port status for a particular node. - */ -@XmlType(name = "nodePortStatus") -public class NodePortStatusDTO { - - private NodeDTO node; - private PortStatusDTO portStatus; - - /** - * The node. - * - * @return - */ - public NodeDTO getNode() { - return node; - } - - public void setNode(NodeDTO node) { - this.node = node; - } - - /** - * The port's status. - * - * @return - */ - public PortStatusDTO getPortStatus() { - return portStatus; - } - - public void setPortStatus(PortStatusDTO portStatus) { - this.portStatus = portStatus; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeProcessorStatusDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeProcessorStatusDTO.java b/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeProcessorStatusDTO.java deleted file mode 100644 index afff4b1..0000000 --- a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeProcessorStatusDTO.java +++ /dev/null @@ -1,57 +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 javax.xml.bind.annotation.XmlType; -import org.apache.nifi.web.api.dto.NodeDTO; - -/** - * DTO for serializing the processor status for a particular node. - */ -@XmlType(name = "nodeProcessorStatus") -public class NodeProcessorStatusDTO { - - private NodeDTO node; - private ProcessorStatusDTO processorStatus; - - /** - * The node. - * - * @return - */ - public NodeDTO getNode() { - return node; - } - - public void setNode(NodeDTO node) { - this.node = node; - } - - /** - * The processor's status. - * - * @return - */ - public ProcessorStatusDTO getProcessorStatus() { - return processorStatus; - } - - public void setProcessorStatus(ProcessorStatusDTO processorStatus) { - this.processorStatus = processorStatus; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeRemoteProcessGroupStatusDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeRemoteProcessGroupStatusDTO.java b/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeRemoteProcessGroupStatusDTO.java deleted file mode 100644 index 03923bf..0000000 --- a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeRemoteProcessGroupStatusDTO.java +++ /dev/null @@ -1,57 +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 javax.xml.bind.annotation.XmlType; -import org.apache.nifi.web.api.dto.NodeDTO; - -/** - * DTO for serializing the remote process group status for a particular node. - */ -@XmlType(name = "nodeRemoteProcessGroupStatus") -public class NodeRemoteProcessGroupStatusDTO { - - private NodeDTO node; - private RemoteProcessGroupStatusDTO remoteProcessGroupStatus; - - /** - * The node. - * - * @return - */ - public NodeDTO getNode() { - return node; - } - - public void setNode(NodeDTO node) { - this.node = node; - } - - /** - * The remote process group's status. - * - * @return - */ - public RemoteProcessGroupStatusDTO getRemoteProcessGroupStatus() { - return remoteProcessGroupStatus; - } - - public void setRemoteProcessGroupStatus(RemoteProcessGroupStatusDTO remoteProcessGroupStatus) { - this.remoteProcessGroupStatus = remoteProcessGroupStatus; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/300952a9/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeStatusDTO.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeStatusDTO.java b/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeStatusDTO.java deleted file mode 100644 index 03647cd..0000000 --- a/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeStatusDTO.java +++ /dev/null @@ -1,57 +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 javax.xml.bind.annotation.XmlType; -import org.apache.nifi.web.api.dto.NodeDTO; - -/** - * DTO for serializing the node status. - */ -@XmlType(name = "nodeStatus") -public class NodeStatusDTO { - - private NodeDTO node; - private ProcessGroupStatusDTO controllerStatus; - - /** - * The node. - * - * @return - */ - public NodeDTO getNode() { - return node; - } - - public void setNode(NodeDTO node) { - this.node = node; - } - - /** - * The controller status. - * - * @return - */ - public ProcessGroupStatusDTO getControllerStatus() { - return controllerStatus; - } - - public void setControllerStatus(ProcessGroupStatusDTO controllerStatus) { - this.controllerStatus = controllerStatus; - } - -}