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")