flink 如何结合流和乘法映射
flink how to combine stream and multiply maps
我有一个流(不是键控流)和 3 个映射(每个映射的结果来自不同的休息 api)。
这3张地图是静态的,之后不会改变。
我想使用这 3 个映射将元素映射到流中的新类型,如何将 3 个映射广播到流?
据我所知,加入或连接不足以做到这一点。请帮忙。
如果地图(如 java 地图)是静态的,您可以将它们加载到 open
中的 RichMapFunction
中,然后在 map
中应用它们。为了提高性能,您应该在静态变量中对它们进行一次初始化(在 class 或静态互斥锁上同步)。
如果地图很小,您也可以在 main
中初始化它们,然后将它们作为参数传递给 MapFunction
。只要地图中的所有内容都是 Serializable
,它就可以正常工作。
我有一个流(不是键控流)和 3 个映射(每个映射的结果来自不同的休息 api)。
这3张地图是静态的,之后不会改变。
我想使用这 3 个映射将元素映射到流中的新类型,如何将 3 个映射广播到流?
据我所知,加入或连接不足以做到这一点。请帮忙。
如果地图(如 java 地图)是静态的,您可以将它们加载到 open
中的 RichMapFunction
中,然后在 map
中应用它们。为了提高性能,您应该在静态变量中对它们进行一次初始化(在 class 或静态互斥锁上同步)。
如果地图很小,您也可以在 main
中初始化它们,然后将它们作为参数传递给 MapFunction
。只要地图中的所有内容都是 Serializable
,它就可以正常工作。