pyspark.RDD.collectWithJobGroup¶
-
抽樣。collectWithJobGroup( groupId:str,描述:str,interruptOnCancel:bool=假 )→列表(T] ¶ -
收集抽樣時,使用這種方法來指定工作小組。
使用
pyspark.InheritableThread與固定線程模式啟用。
抽樣。
collectWithJobGroup
(
groupId:str,描述:str,interruptOnCancel:bool=假
)→列表(T]
¶
收集抽樣時,使用這種方法來指定工作小組。
使用
pyspark.InheritableThread與固定線程模式啟用。