一個spark清洗數據的demo

import sys reload(sys) sys.setdefaultencoding('utf8') import re import json from pyspark.sql import SparkSession from pyspark.sql import Row from pyspark.sql.functions import udf from pyspark.sql.t

>>阅读原文<<