我有一个想要添加到 flink 表中的对象列表。请分享如何创建表寄存器并将对象添加到flink表中。
即
//class
class Something {
String id:
String firstName:
}
//List of Something
List<Something> somethings = new ArrayList<Something>();
如何创建 flink 表并将列表中对象的每个实例作为新记录添加到 flink 表中。该表应包含列 id、名字。
最佳答案
也许最简单的解决方案是执行以下操作:
val env = StreamExecutionEnvironment.getExecutionEnvironment
val tEnv = StreamTableEnvironment.create(env)
val stream = env.fromElements(<Your elements here>) // can be also .fromCollection()
tEnv.registerDataStream("MyTable", stream)
关于java - 在 Java 中将对象列表添加到 flink 表的最佳方法是什么？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/62185550/