classpyspark.streaming.StreamingContext(sparkContext,batchDuration=None,...

11.class pyspark.sql.Window 用于在DataFrame中定义窗口的实用函数。 window=Window.partit...

1class pyspark.sql.types.DataType 数据类型的基类。 10.1 fromInternal(obj) 将内部SQL...

9.1 pyspark.sql.functions.abs(col)：New in version 1.3. 一组内置函数，计算绝对值 9.2 ...

DataFrame的统计函数的功能。 8.1 corr(col1, col2, method=None) 以双精度值计算DataFrame的两列...

新版本1.4之后，在dataframe中处理丢失数据的功能。 7.1 drop(how='any',thresh=None,subset=Non...

由DataFrame.groupBy()创建的DataFrame上的一组聚合方法。 6.1 agg(*exprs) 计算聚合并将结果作为Data...

同pyspark.sql.DataFrame

DataFrame中的一行,其中的字段可以像属性一样访问。 Row可以用来通过使用命名参数来创建一个行对象，字段将按名称排序。 Row也可以用来...