Package org.apache.beam.sdk.schemas.logicaltypes

Class FixedBytes

java.lang.Object

org.apache.beam.sdk.schemas.logicaltypes.PassThroughLogicalType<byte[]>

org.apache.beam.sdk.schemas.logicaltypes.FixedBytes

All Implemented Interfaces:

Serializable, Schema.LogicalType<byte[],byte[]>

public class FixedBytes
extends PassThroughLogicalType<byte[]>

A LogicalType representing a fixed-length byte array.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final String	IDENTIFIER

Method Summary

Modifier and Type	Method	Description
int	getLength()
@Nullable String	getName()
static FixedBytes	of(int byteArrayLength)	Return an instance of FixedBytes with specified byte array length.
static FixedBytes	of(@Nullable String name, int byteArrayLength)	Return an instance of FixedBytes with specified byte array length.
byte[]	toBaseType(byte[] input)	Convert the input type to the type Java type used by the base Schema.FieldType.
byte[]	toInputType(byte[] base)	Convert the Java type used by the base Schema.FieldType to the input type.
String	toString()

Methods inherited from class org.apache.beam.sdk.schemas.logicaltypes.PassThroughLogicalType

getArgument, getArgumentType, getBaseType, getIdentifier

Methods inherited from class java.lang.Object

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

Field Details

IDENTIFIER

public static final String IDENTIFIER

Method Details

of

public static FixedBytes of(@Nullable String name,
 int byteArrayLength)

Return an instance of FixedBytes with specified byte array length.

The name, if set, refers to the TYPE name in the underlying database, for example, BINARY.

of

public static FixedBytes of(int byteArrayLength)

Return an instance of FixedBytes with specified byte array length.

getLength

public int getLength()

getName

public @Nullable String getName()

toBaseType

public byte[] toBaseType(byte[] input)

Description copied from interface: Schema.LogicalType

Convert the input type to the type Java type used by the base Schema.FieldType.

Specified by:

toBaseType in interface Schema.LogicalType<byte[],byte[]>

Overrides:

toBaseType in class PassThroughLogicalType<byte[]>

toInputType

public byte[] toInputType(byte[] base)

Description copied from interface: Schema.LogicalType

Convert the Java type used by the base Schema.FieldType to the input type.

Specified by:

toInputType in interface Schema.LogicalType<byte[],byte[]>

Overrides:

toInputType in class PassThroughLogicalType<byte[]>

toString

public String toString()

Overrides:

toString in class Object