org.apache.beam.sdk.extensions.sql.zetasql

Class DateTimeUtils

java.lang.Object

org.apache.beam.sdk.extensions.sql.zetasql.DateTimeUtils

public class DateTimeUtils
extends java.lang.Object

DateTimeUtils.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.Long	MAX_UNIX_MILLIS
static java.lang.Long	MILLIS_PER_DAY
static java.lang.Long	MIN_UNIX_MILLIS

Constructor Summary

Constructors

Constructor and Description
DateTimeUtils()

Method Summary

Modifier and Type	Method and Description
static DateTimeFormatter	findDateTimePattern(java.lang.String str)
static DateTimeFormatter	findDateTimePattern(java.lang.String str, org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableMap<java.lang.Enum,DateTimeFormatter> patternMap)
static java.lang.String	formatTimestampWithTimeZone(DateTime dt)
static DateTime	parseDate(java.lang.String str)
static com.google.zetasql.Value	parseDateToValue(java.lang.String dateString)
static DateTime	parseTime(java.lang.String str)
static DateTime	parseTimestampWithLocalTimeZone(java.lang.String str)
static DateTime	parseTimestampWithoutTimeZone(java.lang.String str)
static DateTime	parseTimestampWithTimeZone(java.lang.String str)
static com.google.zetasql.Value	parseTimestampWithTZToValue(java.lang.String timestampString)
static DateTime	parseTimestampWithUTCTimeZone(java.lang.String str)
static com.google.zetasql.Value	parseTimeToValue(java.lang.String timeString)
static @Nullable java.lang.Long	validateTimeInterval(@Nullable java.lang.Long arg, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.avatica.util.TimeUnit unit) This function validates that interval is compatible with ZetaSQL timestamp values range.
static @Nullable java.lang.Long	validateTimestamp(@Nullable java.lang.Long ts) This function validates that Long representation of timestamp is compatible with ZetaSQL timestamp values range.

Methods inherited from class java.lang.Object

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

Field Detail

MILLIS_PER_DAY

public static final java.lang.Long MILLIS_PER_DAY

MIN_UNIX_MILLIS

public static final java.lang.Long MIN_UNIX_MILLIS

MAX_UNIX_MILLIS

public static final java.lang.Long MAX_UNIX_MILLIS

Constructor Detail

DateTimeUtils

public DateTimeUtils()

Method Detail

findDateTimePattern

public static DateTimeFormatter findDateTimePattern(java.lang.String str)

findDateTimePattern

public static DateTimeFormatter findDateTimePattern(java.lang.String str,
                                                    org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableMap<java.lang.Enum,DateTimeFormatter> patternMap)

parseTimestampWithUTCTimeZone

public static DateTime parseTimestampWithUTCTimeZone(java.lang.String str)

parseTimestampWithLocalTimeZone

public static DateTime parseTimestampWithLocalTimeZone(java.lang.String str)

parseTimestampWithTimeZone

public static DateTime parseTimestampWithTimeZone(java.lang.String str)

formatTimestampWithTimeZone

public static java.lang.String formatTimestampWithTimeZone(DateTime dt)

parseTimestampWithoutTimeZone

public static DateTime parseTimestampWithoutTimeZone(java.lang.String str)

parseDate

public static DateTime parseDate(java.lang.String str)

parseTime

public static DateTime parseTime(java.lang.String str)

parseDateToValue

public static com.google.zetasql.Value parseDateToValue(java.lang.String dateString)

parseTimeToValue

public static com.google.zetasql.Value parseTimeToValue(java.lang.String timeString)

parseTimestampWithTZToValue

public static com.google.zetasql.Value parseTimestampWithTZToValue(java.lang.String timestampString)

validateTimestamp

public static @Nullable java.lang.Long validateTimestamp(@Nullable java.lang.Long ts)

This function validates that Long representation of timestamp is compatible with ZetaSQL timestamp values range.

Invoked via reflection. @see SqlOperators

Parameters:

ts - Timestamp to validate.

Returns:

Unchanged timestamp sent for validation.

validateTimeInterval

public static @Nullable java.lang.Long validateTimeInterval(@Nullable java.lang.Long arg,
                                                            org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.avatica.util.TimeUnit unit)

This function validates that interval is compatible with ZetaSQL timestamp values range.

ZetaSQL validates that if we represent interval in milliseconds, it will fit into Long.

In case of SECOND or smaller time unit, it converts timestamp to microseconds, so we need to convert those to microsecond and verify that we do not cause overflow.

Invoked via reflection. @see SqlOperators

Parameters:

arg - Argument for the interval.

unit - Time unit used in this interval.

Returns:

Argument for the interval.