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

我有一个要添加到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)