我正在尝试将我的应用程序从spark 2.4.4升级到spark 3.0。我使用以下api来联合javapairdd和list(请参见此处):
union(JavaPairRDD<K,V> first, java.util.List<JavaPairRDD<K,V>> rest)
但是spark3.0(java)中不存在这个api。关于如何克服这个问题有什么建议吗?谢谢!
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!