Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.functions | |
org.apache.flink.table.types | |
org.apache.flink.table.types.utils |
Modifier and Type | Method and Description |
---|---|
static DataTypes.Field |
DataTypes.FIELD(String name,
DataType dataType)
Field definition with field name and data type.
|
static DataTypes.Field |
DataTypes.FIELD(String name,
DataType dataType,
String description)
Field definition with field name, data type, and a description.
|
Modifier and Type | Method and Description |
---|---|
static DataType |
DataTypes.ROW(DataTypes.Field... fields)
Data type of a sequence of fields.
|
static <T> DataType |
DataTypes.STRUCTURED(Class<T> implementationClass,
DataTypes.Field... fields)
Data type of a user-defined object structured type.
|
Modifier and Type | Method and Description |
---|---|
static DataType |
DataTypes.ROW(List<DataTypes.Field> fields) |
Modifier and Type | Method and Description |
---|---|
SpecializedFunction.ExpressionEvaluator |
SpecializedFunction.ExpressionEvaluatorFactory.createEvaluator(Expression expression,
DataType outputDataType,
DataTypes.Field... args)
Creates a serializable factory that can be passed into a
UserDefinedFunction for
evaluating an Expression during runtime. |
SpecializedFunction.ExpressionEvaluator |
SpecializedFunction.ExpressionEvaluatorFactory.createEvaluator(String sqlExpression,
DataType outputDataType,
DataTypes.Field... args)
Shorthand for
createEvaluator(callSql("..."), ...) . |
Modifier and Type | Method and Description |
---|---|
static List<DataTypes.Field> |
DataType.getFields(DataType dataType)
Returns an ordered list of fields starting from the provided
DataType . |
Modifier and Type | Method and Description |
---|---|
static DataType |
DataTypeUtils.appendRowFields(DataType dataType,
List<DataTypes.Field> fields)
Appends the given list of fields to an existing row data type.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.