| /* |
| * 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.registry.flow; |
| |
| import io.swagger.annotations.ApiModelProperty; |
| |
| import javax.xml.bind.annotation.XmlRootElement; |
| import java.util.HashMap; |
| import java.util.HashSet; |
| import java.util.Map; |
| import java.util.Set; |
| |
| @XmlRootElement |
| public class VersionedProcessGroup extends VersionedComponent { |
| |
| private Set<VersionedProcessGroup> processGroups = new HashSet<>(); |
| private Set<VersionedRemoteProcessGroup> remoteProcessGroups = new HashSet<>(); |
| private Set<VersionedProcessor> processors = new HashSet<>(); |
| private Set<VersionedPort> inputPorts = new HashSet<>(); |
| private Set<VersionedPort> outputPorts = new HashSet<>(); |
| private Set<VersionedConnection> connections = new HashSet<>(); |
| private Set<VersionedLabel> labels = new HashSet<>(); |
| private Set<VersionedFunnel> funnels = new HashSet<>(); |
| private Set<VersionedControllerService> controllerServices = new HashSet<>(); |
| private VersionedFlowCoordinates versionedFlowCoordinates = null; |
| |
| private Map<String, String> variables = new HashMap<>(); |
| |
| private String parameterContextName; |
| private String flowfileConcurrency; |
| private String flowfileOutboundPolicy; |
| |
| @ApiModelProperty("The child Process Groups") |
| public Set<VersionedProcessGroup> getProcessGroups() { |
| return processGroups; |
| } |
| |
| public void setProcessGroups(Set<VersionedProcessGroup> processGroups) { |
| this.processGroups = new HashSet<>(processGroups); |
| } |
| |
| @ApiModelProperty("The Remote Process Groups") |
| public Set<VersionedRemoteProcessGroup> getRemoteProcessGroups() { |
| return remoteProcessGroups; |
| } |
| |
| public void setRemoteProcessGroups(Set<VersionedRemoteProcessGroup> remoteProcessGroups) { |
| this.remoteProcessGroups = new HashSet<>(remoteProcessGroups); |
| } |
| |
| @ApiModelProperty("The Processors") |
| public Set<VersionedProcessor> getProcessors() { |
| return processors; |
| } |
| |
| public void setProcessors(Set<VersionedProcessor> processors) { |
| this.processors = new HashSet<>(processors); |
| } |
| |
| @ApiModelProperty("The Input Ports") |
| public Set<VersionedPort> getInputPorts() { |
| return inputPorts; |
| } |
| |
| public void setInputPorts(Set<VersionedPort> inputPorts) { |
| this.inputPorts = new HashSet<>(inputPorts); |
| } |
| |
| @ApiModelProperty("The Output Ports") |
| public Set<VersionedPort> getOutputPorts() { |
| return outputPorts; |
| } |
| |
| public void setOutputPorts(Set<VersionedPort> outputPorts) { |
| this.outputPorts = new HashSet<>(outputPorts); |
| } |
| |
| @ApiModelProperty("The Connections") |
| public Set<VersionedConnection> getConnections() { |
| return connections; |
| } |
| |
| public void setConnections(Set<VersionedConnection> connections) { |
| this.connections = new HashSet<>(connections); |
| } |
| |
| @ApiModelProperty("The Labels") |
| public Set<VersionedLabel> getLabels() { |
| return labels; |
| } |
| |
| public void setLabels(Set<VersionedLabel> labels) { |
| this.labels = new HashSet<>(labels); |
| } |
| |
| @ApiModelProperty("The Funnels") |
| public Set<VersionedFunnel> getFunnels() { |
| return funnels; |
| } |
| |
| public void setFunnels(Set<VersionedFunnel> funnels) { |
| this.funnels = new HashSet<>(funnels); |
| } |
| |
| @ApiModelProperty("The Controller Services") |
| public Set<VersionedControllerService> getControllerServices() { |
| return controllerServices; |
| } |
| |
| public void setControllerServices(Set<VersionedControllerService> controllerServices) { |
| this.controllerServices = new HashSet<>(controllerServices); |
| } |
| |
| @Override |
| public ComponentType getComponentType() { |
| return ComponentType.PROCESS_GROUP; |
| } |
| |
| public void setVariables(Map<String, String> variables) { |
| this.variables = variables; |
| } |
| |
| @ApiModelProperty("The Variables in the Variable Registry for this Process Group (not including any ancestor or descendant Process Groups)") |
| public Map<String, String> getVariables() { |
| return variables; |
| } |
| |
| public void setVersionedFlowCoordinates(VersionedFlowCoordinates flowCoordinates) { |
| this.versionedFlowCoordinates = flowCoordinates; |
| } |
| |
| @ApiModelProperty("The coordinates where the remote flow is stored, or null if the Process Group is not directly under Version Control") |
| public VersionedFlowCoordinates getVersionedFlowCoordinates() { |
| return versionedFlowCoordinates; |
| } |
| |
| @ApiModelProperty("The name of the parameter context used by this process group") |
| public String getParameterContextName() { |
| return parameterContextName; |
| } |
| |
| public void setParameterContextName(String parameterContextName) { |
| this.parameterContextName = parameterContextName; |
| } |
| |
| @ApiModelProperty(value = "The configured FlowFile Concurrency for the Process Group") |
| public String getFlowFileConcurrency() { |
| return flowfileConcurrency; |
| } |
| |
| public void setFlowFileConcurrency(final String flowfileConcurrency) { |
| this.flowfileConcurrency = flowfileConcurrency; |
| } |
| |
| @ApiModelProperty(value = "The FlowFile Outbound Policy for the Process Group") |
| public String getFlowFileOutboundPolicy() { |
| return flowfileOutboundPolicy; |
| } |
| |
| public void setFlowFileOutboundPolicy(final String outboundPolicy) { |
| this.flowfileOutboundPolicy = outboundPolicy; |
| } |
| } |