来源:华校专
浏览 663
扫码
分享
2020-06-07 18:26:56
2.1 属性
.builder = <pyspark.sql.session.Builder object at 0x7f51f134a110>
:一个Builder
实例
.catalog
:一个接口。用户通过它来create、drop、alter、query
底层的数据库、table
以及 function
等
- 可以通过
SparkSession.catalog.cacheTable('tableName')
, 来缓存表;通过SparkSession.catalog.uncacheTable('tableName')
来从缓存中删除该表。
.conf
:spark
的运行时配置接口。通过它,你可以获取、设置spark、hadoop
的配置。
.read
:返回一个DataFrameReader
,用于从外部存储系统中读取数据并返回DataFrame
.readStream
:返回一个DataStreamReader
,用于将输入数据流视作一个DataFrame
来读取
.sparkContext
:返回底层的SparkContext
.streams
:返回一个StreamingQueryManager
对象,它管理当前上下文的所有活动的StreamingQuery
.udf
:返回一个UDFRegistration
,用于UDF
注册
.version
:返回当前应用的spark
版本
当前内容版权归
华校专 或其关联方所有,如需对内容或内容相关联开源项目进行关注与资助,请访问
华校专 .