AvroUtils (Apache Beam 2.9.0)

java.lang.Object
- org.apache.beam.sdk.schemas.utils.AvroUtils

@Experimental(value=SCHEMAS)
public class AvroUtils
extends java.lang.Object

Utils to convert AVRO records to Beam rows.

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method and Description
`static java.lang.Object`	`convertAvroFieldStrict(java.lang.Object value, Schema avroSchema, Schema.FieldType fieldType)` Strict conversion from AVRO to Beam, strict because it doesn't do widening or narrowing during conversion.
`static Schema.FieldType`	`toFieldType(Schema avroSchema)` Converts AVRO schema to Beam field.
`static Row`	`toRowStrict(GenericRecord record, Schema schema)` Strict conversion from AVRO to Beam, strict because it doesn't do widening or narrowing during conversion.
`static Schema`	`toSchema(Schema schema)` Converts AVRO schema to Beam row schema.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

toSchema

public static Schema toSchema(@Nonnull
                              Schema schema)

Converts AVRO schema to Beam row schema.

Parameters:: schema - schema of type RECORD

toFieldType

public static Schema.FieldType toFieldType(@Nonnull
                                           Schema avroSchema)

Converts AVRO schema to Beam field.

toRowStrict

public static Row toRowStrict(@Nonnull
                              GenericRecord record,
                              @Nonnull
                              Schema schema)

Strict conversion from AVRO to Beam, strict because it doesn't do widening or narrowing during conversion.

convertAvroFieldStrict

public static java.lang.Object convertAvroFieldStrict(@Nonnull
                                                      java.lang.Object value,
                                                      @Nonnull
                                                      Schema avroSchema,
                                                      @Nonnull
                                                      Schema.FieldType fieldType)