org.apache.beam.sdk.io.gcp.bigquery

Class AvroUtils

java.lang.Object

org.apache.beam.sdk.io.gcp.bigquery.AvroUtils

public class AvroUtils
extends java.lang.Object

Utils to help convert Apache Avro types to Beam types.

Constructor Summary

Constructors

Constructor and Description
AvroUtils()

Method Summary

Modifier and Type	Method and Description
static java.lang.Object	convertAvroFormat(Schema.Field beamField, java.lang.Object value) Tries to convert an Avro field to Beam field based on the target type of the Beam field.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AvroUtils

public AvroUtils()

Method Detail

convertAvroFormat

public static java.lang.Object convertAvroFormat(Schema.Field beamField,
                                                 java.lang.Object value)

Tries to convert an Avro field to Beam field based on the target type of the Beam field.