diff --git a/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/flow/ScheduledState.java b/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/flow/ScheduledState.java new file mode 100644 index 0000000..e44f73d --- /dev/null +++ b/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/flow/ScheduledState.java @@ -0,0 +1,22 @@ +/* + * 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; + +public enum ScheduledState { + ENABLED, + DISABLED; +} diff --git a/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/flow/VersionedPort.java b/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/flow/VersionedPort.java index f24e386..2b7cccd 100644 --- a/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/flow/VersionedPort.java +++ b/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/flow/VersionedPort.java @@ -22,6 +22,7 @@ import io.swagger.annotations.ApiModelProperty; public class VersionedPort extends VersionedComponent { private PortType type; private Integer concurrentlySchedulableTaskCount; + private ScheduledState scheduledState; @ApiModelProperty("The number of tasks that should be concurrently scheduled for the port.") public Integer getConcurrentlySchedulableTaskCount() { @@ -41,6 +42,15 @@ public class VersionedPort extends VersionedComponent { this.type = type; } + @ApiModelProperty("The scheduled state of the component") + public ScheduledState getScheduledState() { + return scheduledState; + } + + public void setScheduledState(ScheduledState scheduledState) { + this.scheduledState = scheduledState; + } + @Override public ComponentType getComponentType() { if (type == PortType.OUTPUT_PORT) { diff --git a/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/flow/VersionedProcessor.java b/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/flow/VersionedProcessor.java index aef6dcc..416bf42 100644 --- a/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/flow/VersionedProcessor.java +++ b/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/flow/VersionedProcessor.java @@ -17,11 +17,11 @@ package org.apache.nifi.registry.flow; +import io.swagger.annotations.ApiModelProperty; + import java.util.Map; import java.util.Set; -import io.swagger.annotations.ApiModelProperty; - public class VersionedProcessor extends VersionedComponent implements VersionedConfigurableComponent, VersionedExtensionComponent { @@ -42,7 +42,7 @@ public class VersionedProcessor extends VersionedComponent private Long runDurationMillis; private Integer concurrentlySchedulableTaskCount; private Set autoTerminatedRelationships; - + private ScheduledState scheduledState; @ApiModelProperty("The frequency with which to schedule the processor. The format of the value will depend on th value of schedulingStrategy.") public String getSchedulingPeriod() { @@ -190,8 +190,18 @@ public class VersionedProcessor extends VersionedComponent this.style = style; } + @ApiModelProperty("The scheduled state of the component") + public ScheduledState getScheduledState() { + return scheduledState; + } + + public void setScheduledState(ScheduledState scheduledState) { + this.scheduledState = scheduledState; + } + @Override public ComponentType getComponentType() { return ComponentType.PROCESSOR; } + } diff --git a/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/flow/VersionedRemoteGroupPort.java b/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/flow/VersionedRemoteGroupPort.java index ca85ce4..19f76df 100644 --- a/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/flow/VersionedRemoteGroupPort.java +++ b/nifi-registry-core/nifi-registry-data-model/src/main/java/org/apache/nifi/registry/flow/VersionedRemoteGroupPort.java @@ -17,10 +17,10 @@ package org.apache.nifi.registry.flow; -import java.util.Objects; - import io.swagger.annotations.ApiModelProperty; +import java.util.Objects; + public class VersionedRemoteGroupPort extends VersionedComponent { private String remoteGroupId; private Integer concurrentlySchedulableTaskCount; @@ -28,6 +28,7 @@ public class VersionedRemoteGroupPort extends VersionedComponent { private BatchSize batchSize; private ComponentType componentType; private String targetId; + private ScheduledState scheduledState; @ApiModelProperty("The number of task that may transmit flowfiles to the target port concurrently.") public Integer getConcurrentlySchedulableTaskCount() { @@ -75,6 +76,15 @@ public class VersionedRemoteGroupPort extends VersionedComponent { this.targetId = targetId; } + @ApiModelProperty("The scheduled state of the component") + public ScheduledState getScheduledState() { + return scheduledState; + } + + public void setScheduledState(ScheduledState scheduledState) { + this.scheduledState = scheduledState; + } + @Override public int hashCode() { return 923847 + String.valueOf(getName()).hashCode();