map会持续输出list[Bean],每一个List[Bean]都是独立的，然后想针对这个List[Bean]进行复杂olap型的sql计算操作，之前的做法是先把List[Bean]插入数据库，再基于数据库进行sql计算。现在想在dataStream的一个Map里把这个List[Bean]转换成dataset,然后基于把dataset注册成table进行sql计算，尝试了下，发现不允许这样的操作。
还有什么方法能够直接通过flink实现这样的需求呢? -- Sent from: http://apache-flink.147419.n8.nabble.com/
