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 6F783200828 for ; Fri, 13 May 2016 20:07:33 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 6E36316099F; Fri, 13 May 2016 18:07:33 +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 B91D91602BE for ; Fri, 13 May 2016 20:07:32 +0200 (CEST) Received: (qmail 49056 invoked by uid 500); 13 May 2016 18:07:32 -0000 Mailing-List: contact dev-help@apex.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@apex.incubator.apache.org Delivered-To: mailing list dev@apex.incubator.apache.org Received: (qmail 49045 invoked by uid 99); 13 May 2016 18:07:31 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 13 May 2016 18:07:31 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 52F88C21D8 for ; Fri, 13 May 2016 18:07:31 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -5.448 X-Spam-Level: X-Spam-Status: No, score=-5.448 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-1.428] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id pPzK0UKQCWcJ for ; Fri, 13 May 2016 18:07:30 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with SMTP id 329E45F4ED for ; Fri, 13 May 2016 18:07:29 +0000 (UTC) Received: (qmail 48921 invoked by uid 99); 13 May 2016 18:07:29 -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; Fri, 13 May 2016 18:07:29 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 1344FDFADE; Fri, 13 May 2016 18:07:29 +0000 (UTC) From: amberarrow To: dev@apex.incubator.apache.org Reply-To: dev@apex.incubator.apache.org References: In-Reply-To: Subject: [GitHub] incubator-apex-malhar pull request: APEXMALHAR-2077 AbstractSingle... Content-Type: text/plain Message-Id: <20160513180729.1344FDFADE@git1-us-west.apache.org> Date: Fri, 13 May 2016 18:07:29 +0000 (UTC) archived-at: Fri, 13 May 2016 18:07:33 -0000 Github user amberarrow commented on a diff in the pull request: https://github.com/apache/incubator-apex-malhar/pull/273#discussion_r63226693 --- Diff: library/src/main/java/com/datatorrent/lib/io/fs/AbstractSingleFileOutputOperator.java --- @@ -39,10 +41,37 @@ @NotNull protected String outputFileName; + /** + * partitionedFileName string format specifier + e.g. fileName_physicalPartionId -> %s_%d + */ + private String partitionedFileNameformat = "%s_%d"; + + /** + * Derived name for file based on physicalPartitionId + */ + private transient String partitionedFileName; + + /** + * Physical partition id for the current partition. + */ + private transient int physicalPartitionId; + + /** + * Initializing current partition id, partitionedFileName etc. {@inheritDoc} + */ + @Override + public void setup(OperatorContext context) --- End diff -- Ok. Can we at least provide a way to turn off this behavior -- e.g. if the format string is null or the empty string, the operatorId is not appended. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastructure@apache.org or file a JIRA ticket with INFRA. ---