NIFIREG-247 Adding ScheduleState enum and adding field to processor, port, and remote port
This closes #165.
Signed-off-by: Kevin Doran <kdoran@apache.org>
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 @@
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 @@
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 @@
private Long runDurationMillis;
private Integer concurrentlySchedulableTaskCount;
private Set<String> 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 @@
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 @@
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 @@
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();
