From 66479464be67917c308ccc344cfff58da325748c Mon Sep 17 00:00:00 2001 From: Bryan Bende Date: Fri, 15 Sep 2017 14:17:43 -0400 Subject: [PATCH] NIFI-4387 Adding record tag to Parquet processors Signed-off-by: Pierre Villard This closes #2156. --- .../java/org/apache/nifi/processors/parquet/FetchParquet.java | 2 +- .../java/org/apache/nifi/processors/parquet/PutParquet.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/nifi-nar-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/processors/parquet/FetchParquet.java b/nifi-nar-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/processors/parquet/FetchParquet.java index 3536944c16..8014cad5ac 100644 --- a/nifi-nar-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/processors/parquet/FetchParquet.java +++ b/nifi-nar-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/processors/parquet/FetchParquet.java @@ -39,7 +39,7 @@ import java.io.IOException; @SupportsBatching @InputRequirement(InputRequirement.Requirement.INPUT_REQUIRED) -@Tags({"parquet", "hadoop", "HDFS", "get", "ingest", "fetch", "source", "restricted"}) +@Tags({"parquet", "hadoop", "HDFS", "get", "ingest", "fetch", "source", "restricted", "record"}) @CapabilityDescription("Reads from a given Parquet file and writes records to the content of the flow file using " + "the selected record writer. The original Parquet file will remain unchanged, and the content of the flow file " + "will be replaced with records of the selected type. This processor can be used with ListHDFS or ListFile to obtain " + diff --git a/nifi-nar-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/processors/parquet/PutParquet.java b/nifi-nar-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/processors/parquet/PutParquet.java index b9d2e42a39..eb105430a3 100644 --- a/nifi-nar-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/processors/parquet/PutParquet.java +++ b/nifi-nar-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/processors/parquet/PutParquet.java @@ -53,7 +53,7 @@ import java.util.Collections; import java.util.List; @InputRequirement(InputRequirement.Requirement.INPUT_REQUIRED) -@Tags({"put", "parquet", "hadoop", "HDFS", "filesystem", "restricted"}) +@Tags({"put", "parquet", "hadoop", "HDFS", "filesystem", "restricted", "record"}) @CapabilityDescription("Reads records from an incoming FlowFile using the provided Record Reader, and writes those records " + "to a Parquet file. The schema for the Parquet file must be provided in the processor properties. This processor will " + "first write a temporary dot file and upon successfully writing every record to the dot file, it will rename the " +