You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by pv...@apache.org on 2020/05/29 08:29:04 UTC
[nifi] branch master updated: NIFI-7487 - Added batch support and
displayName to ModifyBytes processor
This is an automated email from the ASF dual-hosted git repository.
pvillard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/master by this push:
new 4ced177 NIFI-7487 - Added batch support and displayName to ModifyBytes processor
4ced177 is described below
commit 4ced1775b5da8dae5963a89e4776d99bad37cd41
Author: r65535 <56...@users.noreply.github.com>
AuthorDate: Thu May 28 11:35:30 2020 +0100
NIFI-7487 - Added batch support and displayName to ModifyBytes processor
Signed-off-by: Pierre Villard <pi...@gmail.com>
This closes #4302.
---
.../main/java/org/apache/nifi/processors/standard/ModifyBytes.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ModifyBytes.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ModifyBytes.java
index a2c8efe..e9d164f 100644
--- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ModifyBytes.java
+++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ModifyBytes.java
@@ -30,6 +30,7 @@ import org.apache.nifi.annotation.behavior.EventDriven;
import org.apache.nifi.annotation.behavior.InputRequirement;
import org.apache.nifi.annotation.behavior.InputRequirement.Requirement;
import org.apache.nifi.annotation.behavior.SideEffectFree;
+import org.apache.nifi.annotation.behavior.SupportsBatching;
import org.apache.nifi.annotation.documentation.CapabilityDescription;
import org.apache.nifi.annotation.documentation.Tags;
import org.apache.nifi.components.PropertyDescriptor;
@@ -50,6 +51,7 @@ import org.apache.nifi.util.StopWatch;
@EventDriven
@SideEffectFree
+@SupportsBatching
@Tags({"binary", "discard", "keep"})
@InputRequirement(Requirement.INPUT_REQUIRED)
@CapabilityDescription("Discard byte range at the start and end or all content of a binary file.")
@@ -63,6 +65,7 @@ public class ModifyBytes extends AbstractProcessor {
private final Set<Relationship> relationships;
public static final PropertyDescriptor START_OFFSET = new PropertyDescriptor.Builder()
.name("Start Offset")
+ .displayName("Start Offset")
.description("Number of bytes removed at the beginning of the file.")
.required(true)
.addValidator(StandardValidators.DATA_SIZE_VALIDATOR)
@@ -71,6 +74,7 @@ public class ModifyBytes extends AbstractProcessor {
.build();
public static final PropertyDescriptor END_OFFSET = new PropertyDescriptor.Builder()
.name("End Offset")
+ .displayName("End Offset")
.description("Number of bytes removed at the end of the file.")
.required(true)
.addValidator(StandardValidators.DATA_SIZE_VALIDATOR)
@@ -79,6 +83,7 @@ public class ModifyBytes extends AbstractProcessor {
.build();
public static final PropertyDescriptor REMOVE_ALL = new PropertyDescriptor.Builder()
.name("Remove All Content")
+ .displayName("Remove All Content")
.description("Remove all content from the FlowFile superseding Start Offset and End Offset properties.")
.required(true)
.allowableValues("true", "false")