Package org.apache.beam.sdk.extensions.avro.schemas.utils

Class AvroUtils.AvroConvertType

java.lang.Object

org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.TypeConversion<Type>

org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.ConvertType

org.apache.beam.sdk.extensions.avro.schemas.utils.AvroUtils.AvroConvertType

Enclosing class:

AvroUtils

public static class AvroUtils.AvroConvertType
extends ByteBuddyUtils.ConvertType

Constructor Summary

Constructors

Constructor	Description
AvroConvertType(boolean returnRawType)

Method Summary

Modifier and Type	Method	Description
protected Type	convertDefault(TypeDescriptor<?> type)
protected Type	convertLogicalType(TypeDescriptor<?> type)	Handles JSR-310 (LocalDate, LocalTime, LocalDateTime, Instant) and UUID fields, which StaticSchemaInference infers as Beam Schema.LogicalTypes.

Methods inherited from class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.ConvertType

convertArray, convertByteBuffer, convertCharSequence, convertCollection, convertDateTime, convertEnum, convertIterable, convertList, convertMap, convertPrimitive, primitiveToWrapper

Methods inherited from class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.TypeConversion

convert, shortCircuitReturnNull

Methods inherited from class java.lang.Object

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

Constructor Details

AvroConvertType

public AvroConvertType(boolean returnRawType)

Method Details

convertLogicalType

protected Type convertLogicalType(TypeDescriptor<?> type)

Description copied from class: ByteBuddyUtils.TypeConversion

Handles JSR-310 (LocalDate, LocalTime, LocalDateTime, Instant) and UUID fields, which StaticSchemaInference infers as Beam Schema.LogicalTypes. Subclasses emit code that round-trips through the corresponding static Schema.LogicalType instance (ByteBuddyUtils.JAVA_LOCAL_DATE_LOGICAL_TYPE etc.).

Overrides:

convertLogicalType in class ByteBuddyUtils.ConvertType

convertDefault

protected Type convertDefault(TypeDescriptor<?> type)

Overrides:

convertDefault in class ByteBuddyUtils.ConvertType