Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id B6F10200CE7 for ; Sat, 16 Sep 2017 14:41:35 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id B5AD61609D4; Sat, 16 Sep 2017 12:41:35 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 080B91609D5 for ; Sat, 16 Sep 2017 14:41:34 +0200 (CEST) Received: (qmail 58402 invoked by uid 500); 16 Sep 2017 12:41:34 -0000 Mailing-List: contact commits-help@nifi.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@nifi.apache.org Delivered-To: mailing list commits@nifi.apache.org Received: (qmail 58393 invoked by uid 99); 16 Sep 2017 12:41:34 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 16 Sep 2017 12:41:34 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 65BE6F5616; Sat, 16 Sep 2017 12:41:33 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: pvillard@apache.org To: commits@nifi.apache.org Message-Id: X-Mailer: ASF-Git Admin Mailer Subject: nifi git commit: NIFI-4387 Adding record tag to Parquet processors Date: Sat, 16 Sep 2017 12:41:33 +0000 (UTC) archived-at: Sat, 16 Sep 2017 12:41:35 -0000 Repository: nifi Updated Branches: refs/heads/master eac47e90c -> 66479464b NIFI-4387 Adding record tag to Parquet processors Signed-off-by: Pierre Villard 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 Authored: Fri Sep 15 14:17:43 2017 -0400 Committer: Pierre Villard 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 " +