org.apache.flink.cdc.common.utils

类 DateTimeUtils

java.lang.Object

org.apache.flink.cdc.common.utils.DateTimeUtils

public class DateTimeUtils
extends Object

Utility functions for datetime types: date, time, timestamp.

字段概要

字段

限定符和类型	字段和说明
static int	EPOCH_JULIAN The julian date of the epoch, 1970-01-01.
static long	MILLIS_PER_DAY The number of milliseconds in a day.

构造器概要

构造器

构造器和说明
DateTimeUtils()

方法概要

限定符和类型	方法和说明
static String	formatTimestampMillis(long ts, String format, TimeZone timeZone)
static String	formatUnixTimestamp(long unixTime, String format, TimeZone timeZone) Convert unix timestamp (seconds since '1970-01-01 00:00:00' UTC) to datetime string in the given format.
static String	formatUnixTimestamp(long unixTime, TimeZone timeZone) Convert unix timestamp (seconds since '1970-01-01 00:00:00' UTC) to datetime string in the "yyyy-MM-dd HH:mm:ss" format.
static int	parseDate(String dateStr, String fromFormat) Returns the epoch days since 1970-01-01.
static int	parseDate(String dateStr, String fromFormat, String timezone)
static long	timestampAdd(String timeIntervalUnit, int interval, long timePoint, String timezone)
static Integer	timestampDiff(String timeIntervalUnit, long fromDate, String fromTimezone, long toDate, String toTimezone)
static int	timestampMillisToDate(long ts) Get date from a timestamp.
static int	timestampMillisToTime(long ts) Get time from a timestamp.
static long	unixTimestamp(String dateStr, String format, TimeZone timeZone) Returns the value of the argument as an unsigned integer in seconds since '1970-01-01 00:00:00' UTC.
static long	unixTimestamp(String dateStr, TimeZone timeZone) Returns the value of the argument as an unsigned integer in seconds since '1970-01-01 00:00:00' UTC.

从类继承的方法 java.lang.Object

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

字段详细资料

EPOCH_JULIAN

public static final int EPOCH_JULIAN

The julian date of the epoch, 1970-01-01.

另请参阅:

常量字段值

MILLIS_PER_DAY

public static final long MILLIS_PER_DAY

The number of milliseconds in a day.

This is the modulo 'mask' used when converting TIMESTAMP values to DATE and TIME values.

另请参阅:

常量字段值

构造器详细资料

DateTimeUtils

public DateTimeUtils()

方法详细资料

timestampMillisToDate

public static int timestampMillisToDate(long ts)

Get date from a timestamp.

参数:

ts - the timestamp in milliseconds.

返回:

the date in days.

timestampMillisToTime

public static int timestampMillisToTime(long ts)

Get time from a timestamp.

参数:

ts - the timestamp in milliseconds.

返回:

the time in milliseconds.

parseDate

public static int parseDate(String dateStr,
                            String fromFormat)

Returns the epoch days since 1970-01-01.

parseDate

public static int parseDate(String dateStr,
                            String fromFormat,
                            String timezone)

formatUnixTimestamp

public static String formatUnixTimestamp(long unixTime,
                                         TimeZone timeZone)

Convert unix timestamp (seconds since '1970-01-01 00:00:00' UTC) to datetime string in the "yyyy-MM-dd HH:mm:ss" format.

formatUnixTimestamp

public static String formatUnixTimestamp(long unixTime,
                                         String format,
                                         TimeZone timeZone)

Convert unix timestamp (seconds since '1970-01-01 00:00:00' UTC) to datetime string in the given format.

unixTimestamp

public static long unixTimestamp(String dateStr,
                                 TimeZone timeZone)

Returns the value of the argument as an unsigned integer in seconds since '1970-01-01 00:00:00' UTC.

unixTimestamp

public static long unixTimestamp(String dateStr,
                                 String format,
                                 TimeZone timeZone)

Returns the value of the argument as an unsigned integer in seconds since '1970-01-01 00:00:00' UTC.

formatTimestampMillis

public static String formatTimestampMillis(long ts,
                                           String format,
                                           TimeZone timeZone)

timestampDiff

public static Integer timestampDiff(String timeIntervalUnit,
                                    long fromDate,
                                    String fromTimezone,
                                    long toDate,
                                    String toTimezone)

timestampAdd

public static long timestampAdd(String timeIntervalUnit,
                                int interval,
                                long timePoint,
                                String timezone)