Package org.apache.flink.cdc.common.data

Class LocalZonedTimestampData

java.lang.Object

org.apache.flink.cdc.common.data.LocalZonedTimestampData

All Implemented Interfaces:

Comparable<LocalZonedTimestampData>

@PublicEvolving
public final class LocalZonedTimestampData
extends Object
implements Comparable<LocalZonedTimestampData>

An internal data structure representing data of LocalZonedTimestampType.

This data structure is immutable and consists of a epoch milliseconds and epoch nanos-of-millisecond since epoch 1970-01-01 00:00:00. It might be stored in a compact representation (as a long value) if values are small enough.

Method Summary

Modifier and Type	Method	Description
int	compareTo(LocalZonedTimestampData that)
boolean	equals(Object obj)
static LocalZonedTimestampData	fromEpochMillis(long millisecond)	Creates an instance of LocalZonedTimestampData from epoch milliseconds.
static LocalZonedTimestampData	fromEpochMillis(long millisecond, int epochNanoOfMillisecond)	Creates an instance of LocalZonedTimestampData from epoch milliseconds and a epoch nanos-of-millisecond.
static LocalZonedTimestampData	fromInstant(java.time.Instant instant)	Creates an instance of LocalZonedTimestampData from an instance of Instant.
long	getEpochMillisecond()	Returns the number of epoch milliseconds since epoch 1970-01-01 00:00:00.
int	getEpochNanoOfMillisecond()	Returns the number of epoch nanoseconds (the nanoseconds within the milliseconds).
int	hashCode()
static boolean	isCompact(int precision)	Returns whether the local zoned timestamp data is small enough to be stored in a long of milliseconds.
java.time.Instant	toInstant()	Converts this LocalZonedTimestampData object to a Instant.
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

getEpochMillisecond

public long getEpochMillisecond()

Returns the number of epoch milliseconds since epoch 1970-01-01 00:00:00.

getEpochNanoOfMillisecond

public int getEpochNanoOfMillisecond()

Returns the number of epoch nanoseconds (the nanoseconds within the milliseconds).

The value range is from 0 to 999,999.

toInstant

public java.time.Instant toInstant()

Converts this LocalZonedTimestampData object to a Instant.

compareTo

public int compareTo(LocalZonedTimestampData that)

Specified by:

compareTo in interface Comparable<LocalZonedTimestampData>

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

fromEpochMillis

public static LocalZonedTimestampData fromEpochMillis(long millisecond)

Creates an instance of LocalZonedTimestampData from epoch milliseconds.

The nanos-of-millisecond field will be set to zero.

Parameters:

millisecond - the number of epoch milliseconds since epoch 1970-01-01 00:00:00; a negative number is the number of epoch milliseconds before epoch 1970-01-01 00:00:00

fromEpochMillis

public static LocalZonedTimestampData fromEpochMillis(long millisecond,
                                                      int epochNanoOfMillisecond)

Creates an instance of LocalZonedTimestampData from epoch milliseconds and a epoch nanos-of-millisecond.

Parameters:

millisecond - the number of epoch milliseconds since epoch 1970-01-01 00:00:00; a negative number is the number of epoch milliseconds before epoch 1970-01-01 00:00:00

epochNanoOfMillisecond - the epoch nanoseconds within the millisecond, from 0 to 999,999

fromInstant

public static LocalZonedTimestampData fromInstant(java.time.Instant instant)

Creates an instance of LocalZonedTimestampData from an instance of Instant.

Parameters:

instant - an instance of Instant

isCompact

public static boolean isCompact(int precision)

Returns whether the local zoned timestamp data is small enough to be stored in a long of milliseconds.