pyspark.RDD.pipe

抽样。 管 ( 命令:str,env:可选(Dict(str,str]]=没有一个,checkCode:bool=假 )→pyspark.rdd.RDD(str]

返回一个抽样由管道元素一个分叉的外部过程。

参数

命令 str

命令来运行。

env 东西,可选

环境变量设置。

checkCode bool,可选

是否检查shell命令的返回值。

例子

> > >sc。并行化([' 1 ',' 2 ',”,“3”])。管(“猫”)。收集()(' 1 ',' 2 ',”,“3”)

以前的

pyspark.RDD.persist

下一个

pyspark.RDD.randomSplit