Mailing-List: contact commits-help@beam.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@beam.apache.org
Date: Tue, 28 Nov 2017 00:42:00 +0000 (UTC)
From: "Tobi Vollebregt (JIRA)" <jira@apache.org>
To: commits@beam.apache.org
Message-ID: <JIRA.13121140.1511829627000.329607.1511829720208@Atlassian.JIRA>
In-Reply-To: <JIRA.13121140.1511829627000@Atlassian.JIRA>
References: <JIRA.13121140.1511829627000@Atlassian.JIRA> <JIRA.13121140.1511829627358@jira-lw-us.apache.org>
Subject: [jira] [Updated] (BEAM-3262) Provide a
 withReadableByteChannelFactory on TextIO.Read
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Tue, 28 Nov 2017 00:42:04 -0000


     [ https://issues.apache.org/jira/browse/BEAM-3262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Tobi Vollebregt updated BEAM-3262:
----------------------------------
    Description: 
Hi,

I am prototyping a dataflow job that reads from GPG encrypted files. I got this working, but had to jump through some hoops to supply a new "compression" format to TextIO: I basically had to copy a good part of TextIO.Read only to add a {{withDecompressingChannelFactory}} method similar to {{withWritableByteChannelFactory}} in TextIO.Write.

Would it be possible to add a method {{withDecompressingChannelFactory}} or {{withReadableByteChannelFactory}} to TextIO.Read to allow users to plug in custom decompression/decryption code?

  was:
Hi,

I am prototyping a dataflow job that reads from GPG encrypted files. I got this working, but had to jump through some hoops to supply a new "compression" format to TextIO: I basically had to copy a good part of TextIO.Read only to add a {{public Read withDecompressingChannelFactory(DecompressingChannelFactory decompressingChannelFactory)}} method similar to {{public TypedWrite<UserT, DestinationT> withWritableByteChannelFactory(WritableByteChannelFactory writableByteChannelFactory)}} in TextIO.Write.

Would it be possible to add a method {{withDecompressingChannelFactory}} or {{withReadableByteChannelFactory}} to TextIO.Read to allow users to plug in custom decompression/decryption code?


> Provide a withReadableByteChannelFactory on TextIO.Read
> -------------------------------------------------------
>
>                 Key: BEAM-3262
>                 URL: https://issues.apache.org/jira/browse/BEAM-3262
>             Project: Beam
>          Issue Type: Improvement
>          Components: sdk-java-core
>            Reporter: Tobi Vollebregt
>            Assignee: Kenneth Knowles
>            Priority: Minor
>
> Hi,
> I am prototyping a dataflow job that reads from GPG encrypted files. I got this working, but had to jump through some hoops to supply a new "compression" format to TextIO: I basically had to copy a good part of TextIO.Read only to add a {{withDecompressingChannelFactory}} method similar to {{withWritableByteChannelFactory}} in TextIO.Write.
> Would it be possible to add a method {{withDecompressingChannelFactory}} or {{withReadableByteChannelFactory}} to TextIO.Read to allow users to plug in custom decompression/decryption code?


--
This message was sent by Atlassian JIRA
(v6.4.14#64029)