You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by mc...@apache.org on 2015/01/21 14:04:38 UTC
[26/64] [partial] incubator-nifi git commit: NIFI-270 Made all
changes identified by adam, mark, joey to prep for a cleaner build
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;
- }
-
-}