org.apache.beam.sdk.schemas

Class LogicalTypes.PassThroughLogicalType<T>

java.lang.Object

org.apache.beam.sdk.schemas.LogicalTypes.PassThroughLogicalType<T>

All Implemented Interfaces:

java.io.Serializable, Schema.LogicalType<T,T>

Direct Known Subclasses:

CalciteUtils.CharType, CalciteUtils.DateType, CalciteUtils.TimestampWithLocalTzType, CalciteUtils.TimeType, CalciteUtils.TimeWithLocalTzType

Enclosing class:

LogicalTypes

public abstract static class LogicalTypes.PassThroughLogicalType<T>
extends java.lang.Object
implements Schema.LogicalType<T,T>

A base class for LogicalTypes that use the same Java type as the underlying base type.

See Also:

Serialized Form

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PassThroughLogicalType(java.lang.String identifier, java.lang.String argument, Schema.FieldType fieldType)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getArgument() An optional argument to configure the type.
Schema.FieldType	getBaseType() The base Schema.FieldType used to store values of this type.
java.lang.String	getIdentifier() The unique identifier for this type.
T	toBaseType(T input) Convert the input Java type to one appropriate for the base Schema.FieldType.
T	toInputType(T base) Convert the Java type used by the base Schema.FieldType to the input type.

Methods inherited from class java.lang.Object

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

Constructor Detail

PassThroughLogicalType

protected PassThroughLogicalType(java.lang.String identifier,
                                 java.lang.String argument,
                                 Schema.FieldType fieldType)

Method Detail

getIdentifier

public java.lang.String getIdentifier()

Description copied from interface: Schema.LogicalType

The unique identifier for this type.

Specified by:

getIdentifier in interface Schema.LogicalType<T,T>

getArgument

public java.lang.String getArgument()

Description copied from interface: Schema.LogicalType

An optional argument to configure the type.

Specified by:

getArgument in interface Schema.LogicalType<T,T>

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<T,T>

toBaseType

public T toBaseType(T input)

Description copied from interface: Schema.LogicalType

Convert the input Java type to one appropriate for the base Schema.FieldType.

Specified by:

toBaseType in interface Schema.LogicalType<T,T>

toInputType

public T toInputType(T 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<T,T>