这个类型是怎么定义到flinksql的？

在 Flink SQL 中，可以定义自定义数据类型，并将其用于定义表的列类型。具体而言，可以通过实现 Flink 的 DataType 接口来定义自定义数据类型，然后在 CREATE TABLE 语句中使用该数据类型来定义表的列类型。
以下是一个示例代码，演示如何定义自定义数据类型并将其用于 CREATE TABLE 语句：
java
Copy
import org.apache.flink.api.common.typeinfo.AtomicType;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.java.typeutils.TypeExtractor;
import org.apache.flink.table.api.DataTypes;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.TableSchema;
import org.apache.flink.table.api.Types;
import org.apache.flink.table.functions.ScalarFunction;
import org.apache.flink.table.types.DataType;
import org.apache.flink.table.types.logical.LogicalType;
import org.apache.flink.table.types.logical.LogicalTypeRoot;
import org.apache.flink.table.types.logical.RowType;
import org.apache.flink.table.types.logical.VarCharType;
import org.apache.flink.types.Row;

import java.util.Arrays;

// 定义一个自定义数据类型
public class MyType implements AtomicType {
// 自定义数据类型的值类型
public static class MyValue {
public String value;
public MyValue(String value) {
this.value = value;
}
}

// 获取自定义数据类型的类型信息
@Override
public TypeInformation<MyValue> getTypeInfo() {
    return TypeExtractor.getForClass(MyValue.class);
}

// 获取自定义数据类型的逻辑类型
@Override
public LogicalType getLogicalType() {
    return new VarCharType(VarCharType.MAX_LENGTH);
}

// 将字符串转换为自定义数据类型的值类型
@Override
public MyValue getValue(Object o) {
    return new MyValue((String) o);
}

// 将自定义数据类型的值类型转换为字符串
@Override
public String toString() {
    return "MyType";
}

}

// 定义一个自定义函数，用于将字符串转换为自定义数据类型
class MyTypeFunction extends ScalarFunction {
public MyType eval(String s) {
return new MyType.MyValue(s);
}
}

// 创建一个表，并将自定义数据类型用于定义表的列类型
Table table = tableEnv.sqlQuery("CREATE TABLE myTable (id INT, name MyType) WITH (...)");
在上述代码中，我们首先定义了一个自定义数据类型 MyType，该类型包含一个值类型 MyValue 和一些方法，用于将字符串转换为值类型