org.apache.beam.sdk.io.jdbc

Class LogicalTypes.JdbcLogicalType<T>

java.lang.Object

org.apache.beam.sdk.io.jdbc.LogicalTypes.JdbcLogicalType<T>

All Implemented Interfaces:

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

Direct Known Subclasses:

LogicalTypes.FixedLengthBytes, LogicalTypes.FixedLengthString, LogicalTypes.FixedPrecisionNumeric, LogicalTypes.VariableLengthBytes, LogicalTypes.VariableLengthString

Enclosing class:

LogicalTypes

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

Base class for JDBC logical types.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	argument
protected Schema.FieldType	baseType
protected java.lang.String	identifier

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
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.
int	hashCode()
T	toBaseType(T input) Convert the input Java type to one appropriate for the base Schema.FieldType.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.schemas.Schema.LogicalType

toInputType

Field Detail

identifier

protected final java.lang.String identifier

baseType

protected final Schema.FieldType baseType

argument

protected final java.lang.String argument

Constructor Detail

JdbcLogicalType

protected JdbcLogicalType(java.lang.String identifier,
                          Schema.FieldType baseType,
                          java.lang.String argument)

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>

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object