Vertica如何实现高效和可扩展的机器学习
lipiwang 2024-10-15 18:40 13 浏览 0 评论
在Vertica 8.1中,Vertica推出了一套受欢迎的机器学习算法,包括线性回归,逻辑回归,Kmeans,朴素贝叶斯和SVM。 基于我们最近的基准测试,它们比Apache Spark上的MLlib运行速度更快。 下图显示了Vertica 8.1.0和Spark 2.1.0之间的性能差异(轴上标记的数字为对数刻度)。
Vertica机器学习可以沿着样本大小,特征数量和群集大小进行扩展。 最重要的是,不需要下采样。 Vertica机器学习可以处理的数据的大小仅限于Vertica可以存储的数据的大小。 这样的成就并不巧合。 我们经历了许多迭代,以设计一个平衡的架构来利用Vertica强大的SQL引擎及其最先进的分布式计算框架。
将机器学习能力整合到RDBMS中的价值早已得到认可。在数据库中运行机器学习算法,数据生命周期,最大限度地减少数据移动,大大简化了机器学习工作流程。大多数RDBMS供应商都尝试了不同的方法来整合机器学习。传统的数据库供应商在其集中式系统中开发了机器学习功能MADlib尝试在SQL引擎之上运行机器学习。然而,这些努力在可扩展性方面遇到了类似的挑战。最近,内存分布式系统已成为大数据分析的流行平台,包括机器学习。这些平台(如Apache Spark)仅用作计算引擎,而通过与其他系统(如Hadoop)集成提供持久数据存储。
Vertica的目标是提供两个:可扩展的数据库,也支持可扩展的机器学习。 Vertica机器学习的设计利用Vertica的分布式平台,采用内存处理,并且与SQL引擎优雅地共存。以下文章介绍了设计的关键技术。
Master/Worker 架构
如下图所示,Vertica机器学习利用Vertica的分布式基础架构,并采用Master/Worker架构。 Master能够在任何节点上运行,它控制算法的高级工作流程。 它设置问题,并指示每个Worker使用Vertica的用户定义函数(UDxs)基于本地数据进行迭代学习。 当Master确定算法已经收敛时,它会整合来自每个节点的所有学习并输出模型。
Vertica中的数据是分布式的,机器学习算法利用分布并对节点本地数据进行大量计算,以最小化跨节点数据移动。
In-Memory处理
Vertica采用MPP架构构建。 其执行引擎对于像SQL查询这样的一次通过算法具有高度可扩展性。 然而,机器学习算法往往是迭代的,这意味着我们先前知道我们可以利用缓存来防止从磁盘重复读取。 因此,Vertica已经引入了内存块,以最适合于算法的格式来缓存训练数据。 内存块也用于存储需要从迭代传递到迭代的中间数据。 用户可以控制通过资源管理器为内存块保留多少内存,而不能适应内存或超过其资源预算的数据会自动溢出到磁盘。 即使在资源有限的系统上,这也允许机器学习查询运行。
优化并行性
机器学习算法大部分时间都是CPU限制的。 为了提高算法的速度,重要的是并行化计算。 机器学习算法依靠Vertica的内置机制来确定查询并行性,以确保我们的查询是有效的,而不会过度侵犯系统中其他查询的资源。 这样,Vertica可以在多用户环境中,在并发查询(包括机器学习查询)之间智能平衡资源。
分布式模型存储
机器学习模型以文件形式存储在Vertica自己的分布式文件系统(DFS)中。 模型以Vertica的原生格式表示,用于快速访问。 随着时间的推移,可能会积累大量的模型。 为了方便管理模型,模型将创建为原生Vertica对象,它们支持与表相同级别的访问控制以及所熟悉的SQL语法来列出,更改和删除它们。
最先进的分布式机器学习算法
研究人员和开发人员不断改进现有的分布式机器学习算法并开发新的算法。对于我们引入的每个算法,我们研究了行业的最新进展,并将其实施量化到Vertica的基础设施。由于Vertica的列存储,Projection和数据压缩,分析功能(如COUNT,AVG,MIN / MAX)非常高效。它们已经成为许多数据准备功能的基石,如归一化和缺失值插补。对于某些功能,如百分位数和计数不同,在计算上本质上是昂贵的,approximate版本被开发以加速它们。
上述设计方法使Vertica机器学习具有可扩展性和快速性。如果您还没有尝试过Vertica机器学习,那么很容易开始。默认情况下,机器学习内置于Vertica。不需要安装或配置。您可以在Vertica在线文档中阅读有关Vertica机器学习的更多信息。
号外:喜欢这篇文档,请关注,会有更多更精彩内容奉献!
相关推荐
- Go语言图书管理RESTful API开发实战
-
Go(Golang)是最近流行起来,且相对较新的编程语言。它小而稳定,使用和学习简单,速度快,经过编译(原生代码),并大量用于云工具和服务(Docker、Kubernetes...)。考虑到它所带来的...
- 轻松搞定Golang 中的内存管理(golang设置内存大小)
-
除非您正在对服务进行原型设计,否则您可能会关心应用程序的内存使用情况。内存占用更小,基础设施成本降低,扩展变得更容易/延迟。尽管Go以不消耗大量内存而闻名,但仍有一些方法可以进一步减少消耗。其中一...
- golang实现deepseek 聊天功能(golang deepcopy)
-
在搭建完deepseek环境后在docker内部署deepseekrag环境,我们可以用golang实现聊天功能。在实现这个功能之前,我们先了解下提示词工程(prompt)。大模型虽然知道的东西多...
- golang slice的扩容机制(golang设置内存大小)
-
在Go语言中,切片(slice)是一种动态数组,其长度可以在运行时改变。当向切片中添加元素时,如果切片的容量不足以容纳新元素,就会触发扩容机制。下面详细介绍Go语言切片的扩容机制。扩容触发条件...
- Etcd服务注册与发现封装实现--golang
-
服务注册register.gopackageregisterimport("fmt""time"etcd3"github.com/cor...
- 嘿,轻松获取区间内所有日期的Golang小技巧!
-
在Go语言中,获取两个日期之间的所有日期可以手动实现一个函数来完成。以下是一个示例函数,它会返回一个日期切片,包含从开始日期到结束日期(包括这两个日期)的所有日期:packagemainimpo...
- 仓颉、Java、Golang性能测试——数组扩容
-
版本信息仓颉版本0.53.18Golang版本1.22.8Java版本corretto-1.8.0_452源码仓颉packagecangjie_testimportstd.collect...
- Golang 58个坑 – 中级篇:36-51(golang cef)
-
36.关闭HTTP的响应体37.关闭HTTP连接38.将JSON中的数字解码为interface类型39.struct、array、slice和map的值比较40.从panic...
- 一篇文章学会golang语法,golang简明教程快速入门
-
Go(又称Golang)是Google开发的一种静态强类型、编译型、并发型,并具有垃圾回收功能的编程语言。——Go-wikipedia.org1Go安装最新版本下载地址官方下载https...
- 运维大神如何使用 Golang 日志监控应用程序
-
你是如何使用Golang日志监控你的应用程序的呢?Golang没有异常,只有错误。因此你的第一印象可能就是开发Golang日志策略并不是一件简单的事情。不支持异常事实上并不是什么问题,异常在...
- Golang操作elasticsearch(golang操作word)
-
简介开源的Elasticsearch是目前全文搜索引擎的首选,很多日志都是放到elasticsearch里面,然后再根据具体的需求进行分析。目前我们的运维系统是使用golang开发的,需要定时到e...
- 一文带你看懂Golang最新特性(golang x)
-
作者:腾讯PCG代码委员会经过十余年的迭代,Go语言逐渐成为云计算时代主流的编程语言。下到云计算基础设施,上到微服务,越来越多的流行产品使用Go语言编写。可见其影响力已经非常强大。一、Go语言发展历史...
- Golang 最常用函数(备用查询)(golang函数和方法)
-
hello.gopackagemainimport"fmt"funcmain(){fmt.Println("Hello,world!")}直...
- Golang:将日志以Json格式输出到Kafka
-
在上一篇文章中我实现了一个支持Debug、Info、Error等多个级别的日志库,并将日志写到了磁盘文件中,代码比较简单,适合练手。有兴趣的可以通过这个链接前往:https://github.com/...
- 如何从 PHP 过渡到 Golang?(php转go需要多久)
-
我是PHP开发者,转Go两个月了吧,记录一下使用Golang怎么一步步开发新项目。本着有坑填坑,有错改错的宗旨,从零开始,开始学习。因为我司没有专门的Golang大牛,所以我也只能一步步自己去...
你 发表评论:
欢迎- 一周热门
- 最近发表
- 标签列表
-
- maven镜像 (69)
- undefined reference to (60)
- zip格式 (63)
- oracle over (62)
- date_format函数用法 (67)
- 在线代理服务器 (60)
- shell 字符串比较 (74)
- x509证书 (61)
- localhost (65)
- java.awt.headless (66)
- syn_sent (64)
- settings.xml (59)
- 弹出窗口 (56)
- applicationcontextaware (72)
- my.cnf (73)
- httpsession (62)
- pkcs7 (62)
- session cookie (63)
- java 生成uuid (58)
- could not initialize class (58)
- beanpropertyrowmapper (58)
- word空格下划线不显示 (73)
- jar文件 (60)
- jsp内置对象 (58)
- makefile编写规则 (58)