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