Modifier and Type | Class and Description |
---|---|
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 long |
timestampToInternal(Timestamp ts)
Converts the Java type used for UDF parameters of SQL TIMESTAMP type (
Timestamp ) to internal representation (long). |
static TypeSerializer |
toInternalSerializer(LogicalType logicalType) |
static FlinkFnApi.Schema.FieldType |
toProtoType(LogicalType logicalType) |
public static FlinkFnApi.Schema.FieldType toProtoType(LogicalType logicalType)
public static TypeSerializer toInternalSerializer(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 long timestampToInternal(Timestamp ts)
Timestamp
) to internal representation (long).
Note: The implementation refers to SqlDateTimeUtils.timestampToInternal(java.sql.Timestamp)
.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.