Apache Beam Coder classes

(Last updated: API version 2.0.0)

Coder classes in Beam encapsulate the functionality of serializing and deserializing the values that you might find in a PCollection. Every PCollection has a Coder class associated with it, either because it was set explicitly, or inferred from the type of the values in the PCollection.

To get the default Coder for a given type, you can call:

final CoderRegistry registry = CoderRegistry.createDefault();
registry.getCoder(byte[].class));

Here are the Coder classes provided in Beam 0.6.0's Java API:

Subscribe to All Posts - Wesley Tanaka