public class TypeUtils extends Object
Constructor and Description |
---|
TypeUtils() |
Modifier and Type | Method and Description |
---|---|
static Object |
castFromString(String s,
org.apache.flink.table.types.logical.LogicalType type) |
static org.apache.flink.table.types.logical.RowType |
project(org.apache.flink.table.types.logical.RowType inputType,
int[] mapping) |
static int |
timestampPrecision(org.apache.flink.table.types.logical.LogicalType type) |
static boolean |
toBoolean(org.apache.flink.table.data.binary.BinaryStringData str)
Parse a
StringData to boolean. |
static int |
toDate(org.apache.flink.table.data.binary.BinaryStringData input) |
static int |
toTime(org.apache.flink.table.data.binary.BinaryStringData input) |
static org.apache.flink.table.data.TimestampData |
toTimestamp(org.apache.flink.table.data.binary.BinaryStringData input,
int precision)
Used by
CAST(x as TIMESTAMP) . |
public static org.apache.flink.table.types.logical.RowType project(org.apache.flink.table.types.logical.RowType inputType, int[] mapping)
public static Object castFromString(String s, org.apache.flink.table.types.logical.LogicalType type)
public static int timestampPrecision(org.apache.flink.table.types.logical.LogicalType type)
public static boolean toBoolean(org.apache.flink.table.data.binary.BinaryStringData str) throws org.apache.flink.table.api.TableException
StringData
to boolean.org.apache.flink.table.api.TableException
public static int toDate(org.apache.flink.table.data.binary.BinaryStringData input) throws java.time.DateTimeException
java.time.DateTimeException
public static int toTime(org.apache.flink.table.data.binary.BinaryStringData input) throws java.time.DateTimeException
java.time.DateTimeException
public static org.apache.flink.table.data.TimestampData toTimestamp(org.apache.flink.table.data.binary.BinaryStringData input, int precision) throws java.time.DateTimeException
CAST(x as TIMESTAMP)
.java.time.DateTimeException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.