Package org.apache.flink.cdc.runtime.functions.impl

Class TemporalFunctions

java.lang.Object

org.apache.flink.cdc.runtime.functions.impl.TemporalFunctions

public class TemporalFunctions
extends Object

Temporal built-in functions.

Constructor Summary

Constructors

Constructor	Description
TemporalFunctions()

Method Summary

Modifier and Type	Method	Description
static java.time.LocalDate	currentDate(long epochTime, String timezone)
static java.time.LocalTime	currentTime(long epochTime, String timezone)
static java.time.Instant	currentTimestamp(long epochTime)
static String	dateAdd(String timestamp, int days, String timezone)
static String	dateAdd(java.time.Instant timestamp, int days, String timezone)
static String	dateAdd(java.time.LocalDate timestamp, int days, String timezone)
static String	dateAdd(java.time.LocalDateTime timestamp, int days, String timezone)
static String	dateFormat(java.time.Instant timestamp, String format, String timezone)
static String	dateFormat(java.time.LocalDate date, String format, String timezone)
static String	dateFormat(java.time.LocalDateTime timestamp, String format, String timezone)
static String	dateFormat(java.time.LocalTime time, String format, String timezone)
static String	dateFormatTz(java.time.Instant timestamp, String timezone)
static String	dateFormatTz(java.time.Instant timestamp, String format, String timezone)
static String	dateFormatTz(java.time.LocalDateTime timestamp, String timezone)
static String	dateFormatTz(java.time.LocalDateTime timestamp, String format, String timezone)
static Long	extract(String unit, java.time.temporal.TemporalAccessor temporal, String timezone)
static String	fromUnixtime(Integer seconds, String timezone)
static String	fromUnixtime(Integer seconds, String format, String timezone)
static String	fromUnixtime(Long seconds, String timezone)
static String	fromUnixtime(Long seconds, String format, String timezone)
static java.time.LocalTime	localtime(long epochTime, String timezone)
static java.time.LocalDateTime	localtimestamp(long epochTime, String timezone)
static java.time.Instant	now(long epochTime)
static java.time.Instant	temporalPlusMillis(java.time.Instant temporal, long millis)
static java.time.LocalDate	temporalPlusMillis(java.time.LocalDate temporal, long millis)
static java.time.LocalDateTime	temporalPlusMillis(java.time.LocalDateTime temporal, long millis)
static java.time.LocalTime	temporalPlusMillis(java.time.LocalTime temporal, long millis)
static java.time.Instant	temporalPlusMonths(java.time.Instant temporal, long months)
static java.time.LocalDate	temporalPlusMonths(java.time.LocalDate temporal, long months)
static java.time.LocalDateTime	temporalPlusMonths(java.time.LocalDateTime temporal, long months)
static java.time.LocalTime	temporalPlusMonths(java.time.LocalTime temporal, long months)
static java.time.Instant	timestampadd(String timeIntervalUnit, Integer interval, java.time.Instant timePoint, String timezone)
static java.time.LocalDateTime	timestampadd(String timeIntervalUnit, Integer interval, java.time.LocalDateTime timePoint, String timezone)
static Integer	timestampdiff(String timeIntervalUnit, java.time.Instant fromTimestamp, java.time.Instant toTimestamp, String timezone)
static Integer	timestampdiff(String timeIntervalUnit, java.time.Instant fromTimestamp, java.time.LocalDateTime toTimestamp, String timezone)
static Integer	timestampdiff(String timeIntervalUnit, java.time.LocalDateTime fromTimestamp, java.time.Instant toTimestamp, String timezone)
static Integer	timestampdiff(String timeIntervalUnit, java.time.LocalDateTime fromTimestamp, java.time.LocalDateTime toTimestamp, String timezone)
static Integer	timestampDiff(String timeIntervalUnit, java.time.Instant fromTimestamp, java.time.Instant toTimestamp, String timezone)
static Integer	timestampDiff(String timeIntervalUnit, java.time.Instant fromTimestamp, java.time.LocalDateTime toTimestamp, String timezone)
static Integer	timestampDiff(String timeIntervalUnit, java.time.LocalDateTime fromTimestamp, java.time.Instant toTimestamp, String timezone)
static Integer	timestampDiff(String timeIntervalUnit, java.time.LocalDateTime fromTimestamp, java.time.LocalDateTime toTimestamp, String timezone)
static java.time.LocalDate	toDate(String str)
static java.time.LocalDate	toDate(String str, String format)
static java.time.LocalDate	toDate(java.time.Instant instant)
static java.time.LocalDate	toDate(java.time.LocalDateTime localDateTime)
static java.time.LocalDate	toDate(java.time.ZonedDateTime zonedDateTime)
static java.time.LocalDateTime	toTimestamp(String str, String timezone)
static java.time.LocalDateTime	toTimestamp(String str, String format, String timezone)
static java.time.Instant	toTimestampLtz(Long epochMillis)
static java.time.Instant	toTimestampLtz(Long timestamp, Integer precision)
static java.time.Instant	toTimestampLtz(String timestamp)
static java.time.Instant	toTimestampLtz(String timestamp, String format)
static java.time.Instant	toTimestampLtz(String timestamp, String format, String zoneId)
static long	unixTimestamp(long epochTime, String timezone)
static long	unixTimestamp(String dateTimeStr, long epochTime, String timezone)
static long	unixTimestamp(String dateTimeStr, String format, long epochTime, String timezone)

Methods inherited from class java.lang.Object

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

Constructor Detail

TemporalFunctions

public TemporalFunctions()

Method Detail

currentTimestamp

public static java.time.Instant currentTimestamp(long epochTime)

now

public static java.time.Instant now(long epochTime)

localtimestamp

public static java.time.LocalDateTime localtimestamp(long epochTime,
                                                     String timezone)

localtime

public static java.time.LocalTime localtime(long epochTime,
                                            String timezone)

currentTime

public static java.time.LocalTime currentTime(long epochTime,
                                              String timezone)

currentDate

public static java.time.LocalDate currentDate(long epochTime,
                                              String timezone)

extract

public static Long extract(String unit,
                           java.time.temporal.TemporalAccessor temporal,
                           String timezone)

temporalPlusMonths

public static java.time.LocalDate temporalPlusMonths(java.time.LocalDate temporal,
                                                     long months)

temporalPlusMonths

public static java.time.LocalTime temporalPlusMonths(java.time.LocalTime temporal,
                                                     long months)

temporalPlusMonths

public static java.time.LocalDateTime temporalPlusMonths(java.time.LocalDateTime temporal,
                                                         long months)

temporalPlusMonths

public static java.time.Instant temporalPlusMonths(java.time.Instant temporal,
                                                   long months)

temporalPlusMillis

public static java.time.LocalDate temporalPlusMillis(java.time.LocalDate temporal,
                                                     long millis)

temporalPlusMillis

public static java.time.LocalTime temporalPlusMillis(java.time.LocalTime temporal,
                                                     long millis)

temporalPlusMillis

public static java.time.LocalDateTime temporalPlusMillis(java.time.LocalDateTime temporal,
                                                         long millis)

temporalPlusMillis

public static java.time.Instant temporalPlusMillis(java.time.Instant temporal,
                                                   long millis)

fromUnixtime

public static String fromUnixtime(Integer seconds,
                                  String timezone)

fromUnixtime

public static String fromUnixtime(Integer seconds,
                                  String format,
                                  String timezone)

fromUnixtime

public static String fromUnixtime(Long seconds,
                                  String timezone)

fromUnixtime

public static String fromUnixtime(Long seconds,
                                  String format,
                                  String timezone)

unixTimestamp

public static long unixTimestamp(long epochTime,
                                 String timezone)

unixTimestamp

public static long unixTimestamp(String dateTimeStr,
                                 long epochTime,
                                 String timezone)

unixTimestamp

public static long unixTimestamp(String dateTimeStr,
                                 String format,
                                 long epochTime,
                                 String timezone)

dateFormat

public static String dateFormat(java.time.Instant timestamp,
                                String format,
                                String timezone)

dateFormat

public static String dateFormat(java.time.LocalDateTime timestamp,
                                String format,
                                String timezone)

dateFormat

public static String dateFormat(java.time.LocalDate date,
                                String format,
                                String timezone)

dateFormat

public static String dateFormat(java.time.LocalTime time,
                                String format,
                                String timezone)

toDate

public static java.time.LocalDate toDate(String str)

toDate

public static java.time.LocalDate toDate(String str,
                                         String format)

toDate

public static java.time.LocalDate toDate(java.time.LocalDateTime localDateTime)

toDate

public static java.time.LocalDate toDate(java.time.ZonedDateTime zonedDateTime)

toDate

public static java.time.LocalDate toDate(java.time.Instant instant)

toTimestamp

public static java.time.LocalDateTime toTimestamp(String str,
                                                  String timezone)

toTimestamp

public static java.time.LocalDateTime toTimestamp(String str,
                                                  String format,
                                                  String timezone)

timestampDiff

public static Integer timestampDiff(String timeIntervalUnit,
                                    java.time.LocalDateTime fromTimestamp,
                                    java.time.LocalDateTime toTimestamp,
                                    String timezone)

timestampDiff

public static Integer timestampDiff(String timeIntervalUnit,
                                    java.time.Instant fromTimestamp,
                                    java.time.Instant toTimestamp,
                                    String timezone)

timestampDiff

public static Integer timestampDiff(String timeIntervalUnit,
                                    java.time.Instant fromTimestamp,
                                    java.time.LocalDateTime toTimestamp,
                                    String timezone)

timestampDiff

public static Integer timestampDiff(String timeIntervalUnit,
                                    java.time.LocalDateTime fromTimestamp,
                                    java.time.Instant toTimestamp,
                                    String timezone)

timestampdiff

public static Integer timestampdiff(String timeIntervalUnit,
                                    java.time.LocalDateTime fromTimestamp,
                                    java.time.LocalDateTime toTimestamp,
                                    String timezone)

timestampdiff

public static Integer timestampdiff(String timeIntervalUnit,
                                    java.time.Instant fromTimestamp,
                                    java.time.Instant toTimestamp,
                                    String timezone)

timestampdiff

public static Integer timestampdiff(String timeIntervalUnit,
                                    java.time.Instant fromTimestamp,
                                    java.time.LocalDateTime toTimestamp,
                                    String timezone)

timestampdiff

public static Integer timestampdiff(String timeIntervalUnit,
                                    java.time.LocalDateTime fromTimestamp,
                                    java.time.Instant toTimestamp,
                                    String timezone)

timestampadd

public static java.time.LocalDateTime timestampadd(String timeIntervalUnit,
                                                   Integer interval,
                                                   java.time.LocalDateTime timePoint,
                                                   String timezone)

timestampadd

public static java.time.Instant timestampadd(String timeIntervalUnit,
                                             Integer interval,
                                             java.time.Instant timePoint,
                                             String timezone)

toTimestampLtz

public static java.time.Instant toTimestampLtz(Long epochMillis)

toTimestampLtz

public static java.time.Instant toTimestampLtz(Long timestamp,
                                               Integer precision)

toTimestampLtz

public static java.time.Instant toTimestampLtz(String timestamp)

toTimestampLtz

public static java.time.Instant toTimestampLtz(String timestamp,
                                               String format)

toTimestampLtz

public static java.time.Instant toTimestampLtz(String timestamp,
                                               String format,
                                               String zoneId)

dateFormatTz

public static String dateFormatTz(java.time.LocalDateTime timestamp,
                                  String timezone)

dateFormatTz

public static String dateFormatTz(java.time.LocalDateTime timestamp,
                                  String format,
                                  String timezone)

dateFormatTz

public static String dateFormatTz(java.time.Instant timestamp,
                                  String timezone)

dateFormatTz

public static String dateFormatTz(java.time.Instant timestamp,
                                  String format,
                                  String timezone)

dateAdd

public static String dateAdd(java.time.LocalDateTime timestamp,
                             int days,
                             String timezone)

dateAdd

public static String dateAdd(java.time.Instant timestamp,
                             int days,
                             String timezone)

dateAdd

public static String dateAdd(java.time.LocalDate timestamp,
                             int days,
                             String timezone)

dateAdd

public static String dateAdd(String timestamp,
                             int days,
                             String timezone)