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

V2EX = way to explore

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

已注册用户请登录

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

这是一个创建于 624 天前的主题，其中的信息可能已经有所发展或是发生改变。

如何将给定 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 条回复 2024-01-25 21:36:34 +08:00

XJohn

2024-01-25 21:36:34 +08:00

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