pyspark+jieba分词 数据标注(提取动词)

from pyspark import SparkConf ,SparkContext import jieba.posseg as posseg def merge(list): result=[] for x in range(len(list)): result.extend(list[x]) list.clear() return res

>>阅读原文<<