[jira] [Created] (BEAM-233) Make Registering Avro Specific Records Easier

["Jesse Anderson (JIRA)" <ji...@apache.org>]

Jesse Anderson created BEAM-233:
-----------------------------------

             Summary: 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
            Assignee: Davor Bonaci


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)