240 发简信
IP属地:湖南
  • [SparkSQL] Rdd转化DataFrame 通过StructType为字段添加Schema

    1、开发环境 spark-2.1.0-bin-hadoop2.6 2、Rdd转换成DataFrame,为字段添加列信息 参数 nullable ...

  • [SparkSQL] 列转行lateral view explode函数和FlatMap算子两种方式实现炸裂

    我用了两种方法实现列转行,说一下我平时使用SparkSQL的习惯,我通常1)是先读取HDFS中的文件,包括txt、parquet等格式2)然后通...

  • [SparkSQL] regexp_replace函数使用 去除特殊隐藏字符\n\t\r

    1、函数介绍 REGEXP_REPLACE(inputString, regexString, replacementString)第一个参数:...