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

Class NanosInstant

java.lang.Object

org.apache.beam.sdk.schemas.logicaltypes.NanosInstant

All Implemented Interfaces:

java.io.Serializable, Schema.LogicalType<java.time.Instant,Row>

public class NanosInstant
extends java.lang.Object

A timestamp represented as nanoseconds since the epoch.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	IDENTIFIER
protected Schema	schema

Constructor Summary

Constructors

Constructor	Description
NanosInstant()

Method Summary

Modifier and Type	Method	Description
java.lang.String	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.
java.lang.String	getIdentifier()	The unique identifier for this type.
Row	toBaseType(java.time.Instant input)	Convert the input type to the type Java type used by the base Schema.FieldType.
java.time.Instant	toInputType(Row row)	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

Field Detail

IDENTIFIER

public static final java.lang.String IDENTIFIER

See Also:

Constant Field Values

schema

protected final Schema schema

Constructor Detail

NanosInstant

public NanosInstant()

Method Detail

toBaseType

public Row toBaseType(java.time.Instant input)

Description copied from interface: Schema.LogicalType

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

toInputType

public java.time.Instant toInputType(Row row)

Description copied from interface: Schema.LogicalType

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

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

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