Package 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 Object

Wrapper for fixed byte fields.

Method Summary

Modifier and Type	Method	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(String name, 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 Details

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(String name,
 String namespace)

Convert to an AVRO type.