`
扬州老鬼
  • 浏览: 306271 次
  • 性别: Icon_minigender_1
  • 来自: 苏州
社区版块
存档分类
最新评论

Apache Drill的ValueVector数据结构说明

 
阅读更多
原创,转载请注明出处。
关注很久的hadoop实时计算框架drill终于发布了他的里程碑的第一版本。
官网地址:
http://incubator.apache.org/drill/
目前开始慢慢学习,首先翻译一份官方文档,介绍Apache drill的数据结构ValueVector。
完成于2013年11月03日凌晨0:30

[size=medium]Value Vectors[/size]
本文档的作用是描述定义在Operator之间传递列式数据的时候所需要的数据结构。

Goals
Support Operators Written in Multiple Language(多语言支持)
ValueVector 需要支持使用C/C++/汇编语言的操作。这就需要底层的ByteBuffer在通过JNI传递的时候不需要被修改。ValueVector 一旦被创建之后就不可变。字节码的顺序也需要不用考虑。
Access
随机读取ValueVector元素的时间需要固定,需要解决这个问题, ValueVector中的元素通过在buffer开头中偏移量来进行识别。重复的数字, null值, 变量的宽度的ValueVector利用额外固定的宽度value vector 来索引每一个元素。 当ValueVector 被RecordBatch构建完成之后写操作是不被允许的。
Efficient Subsets of Value Vectors
当一个operator返回一个ValueVector中的子集的value的时候,他应该重用初始的ValueVector。这就需要一种间接层来跳过某些ValueVector中的值。这个间接层是一个偏移量序列,而这个序列引用了原ValueVector中一个偏移量,在子集中同样包含了数值的计数值。

Pool Allocation
ValueVector利用一个或者多个buffer。这些buffer可以从pool中提取出来,在record迭代过程中ValueVector会由于schema的改变而被created或者destroyed。

Homogenous Value Types
在一个ValueVector的每一个value都是相同的类型。RecordBatch的实现负责在schema出现变化的时候创建一个新的Value Vector。


定义

Data Types

权威的value 类型定义的说明文档参见
https://docs.google.com/spreadsheet/ccc?key=0AvUC_YMxQ9UkdE5kbHpfMzE1YlBSSkx0a0NrRnh1cFE#gid=0
其中分为两个Tab:Basic Data Types,Value Vectors

Operators
一个Operator的作用是转换field流。他可以操作Record Batches或者constant values。
Record Batch
一定范围记录的field value集。当每一个batch包含一个schema的时候,Batch可以由Value Vectors组成。
Value Vector
由一个或者多个连续的buffer组成,每一个Value Vector 保存了一些列的value,以及和Value Vetor对应的0个或者多个元数据信息。

Data Structure
ValueVector将数据保存在ByteBuffer中,ByteBuffer他是一段连续的内存。Additional levels of indirection被用来支持变量值的宽度(variable value widths),null值(nullable values),以及重复数据(repeated values)和selection vectors。 levels of indirection主要是一些lookup tables,这些表是由一个或者多个固定宽度的ValueVectors(这些ValueVectors可以合并,比如说存储了null值,或者variable width values)。一个固定宽度的ValueVector,存存储了非空值,非重复值的时候就不需要查询。ValueVector中的元素可以通过将position信息和Stride信息相乘来直接访问。

Fixed Width Values
Fixed width ValueVectors 仅仅包含一段value序列。通过ByteBuf[0] + Index * Stride公式可(index 从0开始)以随机访问Fixed width ValueVectors 的数据。比如INT4类型的数据结构如下图:




Nullable Values
Nullable Values由一个bit 值向量来表示。向量中每一个bit都对应了ValueVector的一个元素。如果某个bit咩有被设置,那么这个value就为null,否则value将会从下面的buffer中提取出来。
下图解释了一个INT4值2,3,6为空的时候NullableValueVector的对应关系:



Repeated Values
repeated ValueVector适用于包含多个值的元素(比如说JSON)。如下图中一个包含offset和count对table被用来指示ValueVector每一个重复的元素。Count等于0表示ValueVector中元素不包含值,注意offset没有被使用:



Variable Width Values
Variable width values保存在ByteBuffer中连续的位置,每一个元素都由一个fixed width ValueVector中的条目表示。一个条目的长度从其下方的数值中提取推算出来。




Repeated Map Vectors
repeated map vector包含一个或者多个map(类似于JSON中的对象数组),map的value会被保存在ByteBuffer中的连续的位置。如果要访问一条记录,就需要一个count-offset的可寻址表。lookup table指向每一个column中第一个重复的filed,而count表示这个column中包含了多少元素。




Selection Vectors
Selection Vectors代表了一个ValueVector的子集。他包含一个能识别ValueVector内部元素的offsets列表。对于一个fixed width ValueVector,,offsets代表了byteBuffer下面的元素的位置。



对于Nullable,repeated,variable width ValueVector,这些offsets指向了相应的lookup
Table。
下图解释了一个ValueVector(他是INT4类型,数值为1。。6)的SelectionVector包含了Int4值2,3,5







  • 大小: 27 KB
  • 大小: 46 KB
  • 大小: 64.8 KB
  • 大小: 52.4 KB
  • 大小: 80.8 KB
  • 大小: 43.5 KB
  • 大小: 45.4 KB
0
0
分享到:
评论

相关推荐

    使用Apache Drill技术

    ### 使用Apache Drill技术详解 #### 一、Apache Drill概述 ...无论是对于数据分析师还是非技术人员,Apache Drill都能提供简单而强大的数据分析能力。随着大数据技术的不断发展,Apache Drill将继续扮演重要的角色。

    Learning Apache Drill 2019.pdf

    《Learning Apache Drill 2019》是一本关于如何使用Apache Drill进行分布式数据源查询和分析的书籍。Apache Drill是一个开源的SQL查询引擎,它能够查询各种数据源,包括Hadoop上的数据、NoSQL数据库、云存储服务和...

    Apache Drill技术手册

    Apache Drill 是一个低延迟的分布式海量数据交互式查询引擎,使用户能够使用 ANSI SQL 兼容语法查询多种类型的数据存储系统,包括本地文件、HDFS、Hive、HBase、MongoDB 等。Drill 的设计目标是为了支持更广泛的数据...

    Learning Apache Drill

    Apache Drill是Google BigQuery团队发起的一个开源项目,它是一个分布式、低延迟的SQL查询引擎,设计用于处理大规模的非结构化和半结构化数据。Apache Drill的目标是提供一种简单、快速的方式来查询和分析大规模的...

    Apache Drill常用函数

    Apache Drill是一款强大的、跨平台的数据查询引擎,专为大数据分析设计。它支持SQL查询语言,使得用户能够方便地处理各种不同类型的数据源,如Hadoop、NoSQL数据库、云存储等。在Apache Drill 1.18版本中,我们找到...

    apache_drill_tutorial.pdf

    - **JSON**:由于Drill广泛支持JSON格式的数据,所以理解JSON的数据结构和语法是必要的。 - **Linux操作系统**:尽管Drill可在多种平台上运行,但教程可能以Linux环境为例,因此熟悉Linux命令行操作是有帮助的。 在...

    Learning Apache Drill Queryand Analyze Distributed Data Sources with SQL

    Learning Apache Drill Queryand Analyze Distributed Data Sources with SQL

    数据整合处理的工具,apache-drill

    通过Apache Drill,企业可以快速地从大量非结构化和半结构化数据中提取价值,为业务决策提供强有力的支持。同时,由于其无需预定义schema,使得数据科学家和分析师可以更加灵活地处理不断变化的数据格局。

    apache-drill-jdbc-plugin:适用于Apache Drill的JDBC插件

    apache-drill-jdbc-plugin 适用于Apache Drill的JDBC插件 下载Apache Drill 0.9。 将代码添加到contrib中,然后用此文件夹中的pom文件替换现有的pom文件。 用mvn构建。 要仅生成软件包,请使用与以下类似的符号:...

    演练:Apache Drill

    Apache Drill是一个分布式MPP查询层,支持针对NoSQL和Hadoop数据存储系统SQL和替代查询语言。 它的部分灵感来自 。 开发者 请阅读以设置和运行Apache Drill。 有关完整的开发人员文档,请参见 更多信息 请参阅或以...

    军士:使用“ Apache”“ Drill”转换和查询数据的工具

    Apache Drill 是一个开源的分布式大数据查询引擎,设计用于无模式(schema-less)的数据湖环境,支持多种文件格式,包括 Parquet、JSON、CSV等。它提供了SQL接口,使得用户能够轻松地对大规模分布式存储的数据进行...

    drill-domain-tools:一组用于处理Internet域名的Apache Drill UDF

    一组用于处理Internet域名的Apache Drill UDF UDFs 有一个UDF: suffix_extract(domain-string) :给定一个有效的互联网域名(FQDN或其他方式),这将返回一个地图的领域tld , assigned , subdomain和hostname的...

    cb-drill:Apache Drill的存储插件

    Apache Drill的核心特性在于其无模式(schema-less)查询,这意味着它无需预先了解数据结构,就能对数据进行分析。 在"cb-drill"中,"cb"可能是用户或项目名,"drill"代表Apache Drill。描述中的"存储插件"是指...

    drill-twitter-text:一个Apache Drill UDF,用于通过twitter-text Java库(https

    一个Apache Drill UDF,用于通过 Java库处理Twitter tweet文本。 UDFs tw_parse_tweet(string) :解析tweet文本并返回具有以下命名值的地图列: weightedLength :(整数)tweet的总长度,其中代码点按配置文件中...

    drill-html-tools:Apache Drill UDF用于检索和使用HTML文本

    Apache Drill UDF用于检索和使用HTML文本 基于库。 注意:这绝对是一个在制品。 UDFs soup_read_html(url-string, timeout-ms) :此UDF要求网络可到达预期的URL目标。 给定一个URL和一个连接超时(以毫秒为单位)...

    数据分析工具:Apache Drill.zip

    史上最全大数据技术全套教程,包括: 分布式存储系统 大数据基础 大数据处理框架 大数据管理与监控 实时计算 数据仓库 数据分析工具 数据湖 数据集成工具 消息队列 等流行技术的系列教程

    Python库 | sqlalchemy_drill-0.2.1.dev0-py3-none-any.whl

    Apache Drill是一个开源的、无模式的大数据查询引擎,允许用户对各种数据源进行SQL查询,包括Hadoop、NoSQL数据库、云存储等。而`sqlalchemy_drill`是SQLAlchemy的一个扩展,它为SQLAlchemy提供了一个适配器,使得...

    drillnode:Apache Drill的Node.js客户端

    Apache Drill的Node.js客户端Drillnode是使用REST API从Node.js连接并在Apache Drill上执行查询的客户端。安装使用NPM软件包管理器安装Drillone npm install drillnode入门// Requirementsconst Drill = require ( '...

    drill-sergeant:用于 Apache Drill 的 Ruby 客户端

    用于 Apache Drill 的 Ruby 客户端 安装 首先, 。 对于 Homebrew,请使用: brew install apache-drill drill-embedded 并将这一行添加到您的应用程序的 Gemfile 中: gem 'drill-sergeant' 如何使用 创建...

    drill-url-tools:一组用于URL的Apache Drill UDF

    网址工具一组用于URL的Apache Drill UDF 它使用 Java库进行解析。UDFs 包括以下UDF: url_parse(url-string) :输入URL / URI字符串后,将在地图中返回一组字段( url , scheme , username , password , host ,...

Global site tag (gtag.js) - Google Analytics