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

Class OneOfType

java.lang.Object

org.apache.beam.sdk.schemas.logicaltypes.OneOfType

All Implemented Interfaces:

Serializable, Schema.LogicalType<OneOfType.Value,Row>

public class OneOfType
extends Object
implements Schema.LogicalType<OneOfType.Value,Row>

A logical type representing a union of fields. This logical type is initialized with a set of field and represents a union of those fields. This logical type is backed by a Row object containing one nullable field matching each input field, and one additional EnumerationType logical type field that indicates which field is set.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	OneOfType.Value	Represents a single OneOf value.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	IDENTIFIER

Method Summary

Modifier and Type	Method	Description
static OneOfType	create(List<Schema.Field> fields)	Create an OneOfType logical type.
static OneOfType	create(List<Schema.Field> fields, Map<String,Integer> enumValues)	Create an OneOfType logical type.
static OneOfType	create(Schema.Field... fields)	Create an OneOfType logical type.
<T extends @NonNull Object> OneOfType.Value	createValue(int caseValue, T value)	Create a OneOfType.Value specifying which field to set and the value to set.
<T extends @NonNull Object> OneOfType.Value	createValue(String caseValue, T value)	Create a OneOfType.Value specifying which field to set and the value to set.
<T extends @NonNull Object> OneOfType.Value	createValue(EnumerationType.Value caseType, T value)	Create a OneOfType.Value specifying which field to set and the value to set.
byte[]	getArgument()	An optional argument to configure the type.
Schema.FieldType	getArgumentType()	A schema type representing how to interpret the argument.
Schema.FieldType	getBaseType()	The base Schema.FieldType used to store values of this type.
EnumerationType	getCaseEnumType()	Returns the EnumerationType that is used to represent the case type.
Schema.FieldType	getFieldType(OneOfType.Value oneOneValue)
String	getIdentifier()	The unique identifier for this type.
Schema	getOneOfSchema()	Returns the schema of the underlying Row that is used to represent the union.
Row	toBaseType(OneOfType.Value input)	Convert the input type to the type Java type used by the base Schema.FieldType.
OneOfType.Value	toInputType(Row base)	Convert the Java type used by the base Schema.FieldType to the input type.
String	toString()

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

See Also:

• Constant Field Values

Method Details

create

public static OneOfType create(Schema.Field... fields)

Create an OneOfType logical type.

create

public static OneOfType create(List<Schema.Field> fields)

Create an OneOfType logical type.

create

public static OneOfType create(List<Schema.Field> fields,
 Map<String,Integer> enumValues)

Create an OneOfType logical type. This method allows control over the integer values in the generated enum.

getOneOfSchema

public Schema getOneOfSchema()

Returns the schema of the underlying Row that is used to represent the union.

getCaseEnumType

public EnumerationType getCaseEnumType()

Returns the EnumerationType that is used to represent the case type.

getIdentifier

public String getIdentifier()

Description copied from interface: Schema.LogicalType

The unique identifier for this type.

Specified by:

getIdentifier in interface Schema.LogicalType<OneOfType.Value,Row>

getArgumentType

public Schema.FieldType getArgumentType()

Description copied from interface: Schema.LogicalType

A schema type representing how to interpret the argument. null indicates this logical type is not parameterized by an argument.

Specified by:

getArgumentType in interface Schema.LogicalType<OneOfType.Value,Row>

getArgument

public byte[] getArgument()

Description copied from interface: Schema.LogicalType

An optional argument to configure the type.

Specified by:

getArgument in interface Schema.LogicalType<OneOfType.Value,Row>

getBaseType

public Schema.FieldType getBaseType()

Description copied from interface: Schema.LogicalType

The base Schema.FieldType used to store values of this type.

Specified by:

getBaseType in interface Schema.LogicalType<OneOfType.Value,Row>

createValue

public <T extends @NonNull Object> OneOfType.Value createValue(String caseValue,
 T value)

Create a OneOfType.Value specifying which field to set and the value to set.

createValue

public <T extends @NonNull Object> OneOfType.Value createValue(int caseValue,
 T value)

Create a OneOfType.Value specifying which field to set and the value to set.

createValue

public <T extends @NonNull Object> OneOfType.Value createValue(EnumerationType.Value caseType,
 T value)

Create a OneOfType.Value specifying which field to set and the value to set.

getFieldType

public Schema.FieldType getFieldType(OneOfType.Value oneOneValue)

toBaseType

public Row toBaseType(OneOfType.Value 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<OneOfType.Value,Row>

toInputType

public OneOfType.Value toInputType(Row 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<OneOfType.Value,Row>

toString

public String toString()

Overrides:

toString in class Object