我有一个流(不是键控流(和3个映射(每个映射的结果来自不同的rest api(。
这3张地图是静态的,之后不会改变。
我想通过使用这3个映射将元素映射到流中的新类型,如何将3个映射广播到流?
据我所知,仅仅加入或连接是不够的。。请帮忙。
如果映射(如java映射(是静态的,则可以在open
中的RichMapFunction
中加载它们,并在map
中应用它们。为了提高性能,应该在静态变量中初始化它们一次(类或静态互斥对象上的同步(。如果映射很小,您也可以在main
中初始化它们,并将它们作为参数传递给MapFunction
。只要地图中的所有内容都是Serializable
,它就会正常工作。