求助：如何将给定 Java 基本类型的 Class 对象转换为 Flink 的 DataType？

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

For Existing Member Sign In

• 请不要在回答技术问题时复制粘贴 AI 生成的内容

This topic created in 836 days ago, the information mentioned may be changed or developed.

如何将给定 Java 基本类型的 Class 对象转换为 Flink 的 DataType ？就像这样：

    public static RowType convertToDataType(Class<?> pojo) {
        ...
    }

    Field[] fields = pojo.getDeclaredFields();
	for (Field field : fields) {
		if (Modifier.isStatic(field.getModifiers())) {
			continue;
		}
		String fieldName = field.getName();
		DataType fieldType = convertToDataType(field.getType());
		RowType.RowField rowField = new RowType.RowField(fieldName, fieldType.getLogicalType());
		rowFields.add(rowField);
	}

我在 Flink 的内置函数中，没有找到用于转换的方法。这种情况只能自己写方法吗？类似：

private static DataType convertToDataType(Class<?> clazz) {
        if (clazz == CharSequence.class) {
            return DataTypes.STRING();
        }
        if (clazz == String.class) {
            return DataTypes.STRING();
        }
        if (clazz == int.class || clazz == Integer.class) {
            return DataTypes.INT();
        }
        ...
}

1 replies • 2024-01-25 21:36:34 +08:00

XJohn

Jan 25, 2024

你们是想做低代码，运行时判断字段类型么？那可以提前生成 schema 。（比如 JsonRowDeserializationSchema ）
如果是编译期就能确定类型的话直接用 TypeInformation.of()就可以。