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

Class AvroUtils.FixedBytesField

java.lang.Object

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

Enclosing class:

AvroUtils

public static class AvroUtils.FixedBytesField
extends java.lang.Object

Wrapper for fixed byte fields.

Method Summary

Modifier and Type	Method and Description
static @Nullable AvroUtils.FixedBytesField	fromAvroType(Schema type) Create a AvroUtils.FixedBytesField from an AVRO type.
static @Nullable AvroUtils.FixedBytesField	fromBeamFieldType(Schema.FieldType fieldType) Create a AvroUtils.FixedBytesField from a Beam Schema.FieldType.
int	getSize() Get the size.
Schema	toAvroType(java.lang.String name, java.lang.String namespace) Convert to an AVRO type.
Schema.FieldType	toBeamType() Convert to a Beam type.
static AvroUtils.FixedBytesField	withSize(int size) Create a AvroUtils.FixedBytesField with the specified size.

Methods inherited from class java.lang.Object

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

Method Detail

withSize

public static AvroUtils.FixedBytesField withSize(int size)

Create a AvroUtils.FixedBytesField with the specified size.

fromBeamFieldType

public static @Nullable AvroUtils.FixedBytesField fromBeamFieldType(Schema.FieldType fieldType)

Create a AvroUtils.FixedBytesField from a Beam Schema.FieldType.

fromAvroType

public static @Nullable AvroUtils.FixedBytesField fromAvroType(Schema type)

Create a AvroUtils.FixedBytesField from an AVRO type.

getSize

public int getSize()

Get the size.

toBeamType

public Schema.FieldType toBeamType()

Convert to a Beam type.

toAvroType

public Schema toAvroType(java.lang.String name,
                         java.lang.String namespace)

Convert to an AVRO type.