网站介绍:文章浏览阅读994次。背景在写spark程序时,也可以调用别的语言写成的外部程序来进行一些运算方法主要方法就是在spark里调用pipe()函数,来指定要执行的文件以及传入的参数。代码如下 // pipe()函数调用外部程序 val cFile = "C:/Users/songzeceng/test.exe" val pipeOut = testRDD.pipe(Seq(cFi..._spark外部函数
- 链接地址:https://blog.csdn.net/qq_37475168/article/details/103547548
- 链接标题:Spark调用外部程序_spark外部函数-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:5991
- 网站标签:spark外部函数