nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pvill...@apache.org
Subject nifi git commit: NIFI-4387 Adding record tag to Parquet processors
Date Sat, 16 Sep 2017 12:41:33 GMT
Repository: nifi
Updated Branches:
  refs/heads/master eac47e90c -> 66479464b


NIFI-4387 Adding record tag to Parquet processors

Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>

This closes #2156.


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/66479464
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/66479464
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/66479464

Branch: refs/heads/master
Commit: 66479464be67917c308ccc344cfff58da325748c
Parents: eac47e9
Author: Bryan Bende <bbende@apache.org>
Authored: Fri Sep 15 14:17:43 2017 -0400
Committer: Pierre Villard <pierre.villard.fr@gmail.com>
Committed: Sat Sep 16 14:41:07 2017 +0200

----------------------------------------------------------------------
 .../main/java/org/apache/nifi/processors/parquet/FetchParquet.java | 2 +-
 .../main/java/org/apache/nifi/processors/parquet/PutParquet.java   | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/nifi/blob/66479464/nifi-nar-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/processors/parquet/FetchParquet.java
----------------------------------------------------------------------
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 3536944..8014cad 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 " +

http://git-wip-us.apache.org/repos/asf/nifi/blob/66479464/nifi-nar-bundles/nifi-parquet-bundle/nifi-parquet-processors/src/main/java/org/apache/nifi/processors/parquet/PutParquet.java
----------------------------------------------------------------------
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 b9d2e42..eb10543 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 " +


Mime
View raw message