我想在flatmap函数或customer触发器中使用一些其他广播资源，比如list或map，但是我没有找到一些api来满足。我找到了broadcast方法，但它返回的是数据流，如何将其转换为list，如何在streamcontext中获取它？我用的是flink-1.3.2。
4ioopgfo1#
如果你指的是flink的广播状态，那么这只是Flink1.5的介绍。如果你指的是 DataStream#broadcast() 它控制记录的分区，则不允许您指定广播状态。您必须通过指定相应的 CoFlatMapFunction ，例如。
DataStream#broadcast()
CoFlatMapFunction
1条答案
按热度按时间4ioopgfo1#
如果你指的是flink的广播状态，那么这只是Flink1.5的介绍。
如果你指的是
DataStream#broadcast()它控制记录的分区，则不允许您指定广播状态。您必须通过指定相应的CoFlatMapFunction，例如。