org.apache.beam.sdk.io

Interface AvroIO.RecordFormatter<ElementT>

All Superinterfaces:

java.io.Serializable

Enclosing class:

AvroIO

public static interface AvroIO.RecordFormatter<ElementT>
extends java.io.Serializable

Formats an element of a user type into a record with the given schema.

Method Summary

Modifier and Type	Method and Description
GenericRecord	formatRecord(ElementT element, Schema schema)

Method Detail

formatRecord

GenericRecord formatRecord(ElementT element,
                           Schema schema)