java - 在 Java 中将对象列表添加到 flink 表的最佳方法是什么？

Question

我有一个想要添加到 flink 表中的对象列表。请分享如何创建表寄存器并将对象添加到flink表中。

即

//class
class Something {
    String id:
    String firstName: 
}

//List of Something 
List<Something> somethings = new ArrayList<Something>();

如何创建 flink 表并将列表中对象的每个实例作为新记录添加到 flink 表中。该表应包含列 id、名字。

Answer 1

也许最简单的解决方案是执行以下操作:

  val env = StreamExecutionEnvironment.getExecutionEnvironment
  val tEnv =  StreamTableEnvironment.create(env)
  val stream = env.fromElements(<Your elements here>) // can be also .fromCollection()
    tEnv.registerDataStream("MyTable", stream)