Mailing-List: contact commits-help@beam.incubator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@beam.incubator.apache.org
Date: Tue, 3 May 2016 16:50:13 +0000 (UTC)
From: "Kenneth Knowles (JIRA)" <jira@apache.org>
To: commits@beam.incubator.apache.org
Message-ID: <JIRA.12963303.1461791387000.99554.1462294213100@Atlassian.JIRA>
In-Reply-To: <JIRA.12963303.1461791387000@Atlassian.JIRA>
References: <JIRA.12963303.1461791387000@Atlassian.JIRA> <JIRA.12963303.1461791387527@arcas>
Subject: [jira] [Updated] (BEAM-233) Make Registering Avro Specific Records
 Easier
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Tue, 03 May 2016 16:50:21 -0000


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

Kenneth Knowles updated BEAM-233:
---------------------------------
    Labels: starter  (was: )

> Make Registering Avro Specific Records Easier
> ---------------------------------------------
>
>                 Key: BEAM-233
>                 URL: https://issues.apache.org/jira/browse/BEAM-233
>             Project: Beam
>          Issue Type: Bug
>          Components: sdk-java-core
>            Reporter: Jesse Anderson
>              Labels: starter
>
> There should be a helper method to make it easier to register Avro specific record classes. This will be the most common type that needs to be registered. The code would look something like:
> {code:java}
> public class AvroHelper {
>     public static void registerAvro(Pipeline p, Class<? extends SpecificRecordBase> clazz) {
>         p.getCoderRegistry().registerCoder(clazz, new CoderFactory() {
>             @Override
>             public Coder<?> create(List<? extends Coder<?>> componentCoders) {
>                 return AvroCoder.of(clazz);
>             }
>             @Override
>             public List<Object> getInstanceComponents(Object value) {
>                 return null;
>             }
>         });
>     }
> }
> {code}
> With usage:
> {code:java}
>         Pipeline p = Pipeline.create(options);
>         
>         AvroHelper.registerAvro(p, LogEntry.class);
> {code}


--
This message was sent by Atlassian JIRA
(v6.3.4#6332)