Spark SQL 源码分析(四):SessionCatalog

栏目: 编程工具 · 发布时间: 7年前

SessionCatalog 是底层元数据(基于内存和基于 Hive)的代理,同时也负责临时视图和函数的管理。

SessionCatalog 类图:

Spark SQL 源码分析(四):SessionCatalog

ExternalCatalog

ExternalCatalog 用于管理数据库、表、分区和函数,在 Spark SQL 中具体有两个实现:

InMemoryCatalog
HiveExternalCatalog

InMemoryCatalog

ExternalCatalog 基于内存(内部使用 scala.collection.mutable.HashMap )的实现,主要用于测试和探索。不建议用于生产环境。

HiveExternalCatalog

ExternalCatalog 基于 Hive(内部使用 org.apache.hadoop.hive.ql.metadata.Hive )的实现。

GlobalTempViewManager

GlobalTempViewManager 是线程安全的全局临时视图管理器,提供了对全局视图的原子操作,包括创建、更新和删除等。

内部由 scala.collection。mutable.HashMap[String, LogicalPlan] 实现。

FunctionResourceLoader

TODO

FunctionRegistry

提供了函数的注册、查找和删除等功能。

默认实现类 org.apache.spark.sql.catalyst.analysis.SimpleFunctionRegistry

基于 Spark 2.3.0 版本


以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网

查看所有标签

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

O2O进化论

O2O进化论

板砖大余、姜亚东 / 中信出版社 / 2014-5 / 49

在互联网的1.0时代,Online的商业和Offline的商业就像是两条平行线,没有交汇点,在移动浪潮下,他们正在交汇,这就是O2O(Online to Offline)。于是,人们认为:O2O就是线下将线上作为销售前台。结论是对的,但并非简单相加就可以达到。人们已经进入数据革命时期,O2O是线上和线下全流通的数据化工具,电子商务就是非数据商品的数据化。其次,O2O还是一种竞争格局。这决定了以O2......一起来看看 《O2O进化论》 这本书的介绍吧!

Base64 编码/解码
Base64 编码/解码

Base64 编码/解码

MD5 加密
MD5 加密

MD5 加密工具

正则表达式在线测试
正则表达式在线测试

正则表达式在线测试