“Spark DataFrame 基础入门”实验报告

DataFrame 基本概念学习

DataFrame based on Spark 实验报告

列转换类型(自动放在最后) 图片描述 平均晚点时间,用 val averageDelays = df_4.groupBy(df_4.col("FlightNum")).agg(avg(df_4.col("ArrDelay")), avg(df_4.col("DepDelay"))) groupBy是集成多列 avg(df_4.col("ArrDelay"))是计算一列的平均值图片描述 图片描述

最新评论
暂无评论~