Modifier and Type | Class and Description |
---|---|
static class |
PythonTypeUtils.LogicalTypeToConversionClassConverter
Convert LogicalType to conversion class for flink planner.
|
static class |
PythonTypeUtils.LogicalTypeToProtoTypeConverter
Converter That convert the logicalType to the related Prototype.
|
Constructor and Description |
---|
PythonTypeUtils() |
Modifier and Type | Method and Description |
---|---|
static int |
dateToInternal(Date date)
Converts the Java type used for UDF parameters of SQL DATE type (
Date ) to
internal representation (int). |
static BigDecimal |
fromBigDecimal(BigDecimal bigDecimal,
int precision,
int scale)
Convert the specified bigDecimal according to the specified precision and scale.
|
static Date |
internalToDate(int v)
Converts the internal representation of a SQL DATE (int) to the Java type used for UDF
parameters (
Date ). |
static Timestamp |
internalToTimestamp(long v)
Converts the internal representation of a SQL TIMESTAMP (long) to the Java type used for UDF
parameters (
Timestamp ). |
static long |
timestampToInternal(Timestamp ts)
Converts the Java type used for UDF parameters of SQL TIMESTAMP type (
Timestamp ) to internal representation (long). |
static TypeSerializer |
toBlinkTypeSerializer(LogicalType logicalType) |
static TypeSerializer |
toFlinkTypeSerializer(LogicalType logicalType) |
public static TypeSerializer toFlinkTypeSerializer(LogicalType logicalType)
public static TypeSerializer toBlinkTypeSerializer(LogicalType logicalType)
public static BigDecimal fromBigDecimal(BigDecimal bigDecimal, int precision, int scale)
Note: The implementation refers to DecimalData.fromBigDecimal(java.math.BigDecimal, int, int)
.
public static Date internalToDate(int v)
Date
).
Note: The implementation refers to SqlDateTimeUtils.internalToDate(int)
.
public static int dateToInternal(Date date)
Date
) to
internal representation (int).
Note: The implementation refers to SqlDateTimeUtils.dateToInternal(java.sql.Date)
.
public static Timestamp internalToTimestamp(long v)
Timestamp
).
Note: The implementation refers to SqlDateTimeUtils.internalToTimestamp(long)
.
public static long timestampToInternal(Timestamp ts)
Timestamp
) to internal representation (long).
Note: The implementation refers to SqlDateTimeUtils.timestampToInternal(java.sql.Timestamp)
.
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.