使用python编写csv转parquet脚本

from pyspark import SparkContext from pyspark.sql import SQLContext from pyspark.sql.types import * def parse(line):     items = line.split(",")     return (long(items[0]), items[1], float(items[2]),

>>阅读原文<<