首页
学习
活动
专区
圈层
工具
发布
    • 综合排序
    • 最热优先
    • 最新优先
    时间不限
  • 来自专栏开源心路

    Phoenix优化

    那么索引数据的导入还需要采用phoenix提供的索引同步工具类 IndexTool , 这是一个mapreduce工具类,使用方式如下: $HBASE_HOME/bin/hbase org.apache.phoenix.mapreduce.index.IndexTool

    30810编辑于 2023-06-29
  • 来自专栏Spark学习技巧

    实战phoenix

    一 安装部署 1, 下载 http://archive.apache.org/dist/phoenix/ 本文下载的是apache-phoenix-4.12.0-HBase-1.2-bin.tar.gz 在phoenix的bin目录下执行: sqlline.py [zookeeper] . 映射hbase表到phoenix: 比如,在hbase上创建表t1,然后映射到phoenix上,分两步: 1, 创建hbase表 create 't1', {NAME => 'f1', VERSIONS VARCHAR) Hbase表中插入一条数据,phoenix表中查询 put 't1','1001','f1:VAL','lisi' 同时创建hbase和phoenix表: 也可以直接使用cteate :Sqoop导入导出数据练习 3,kafka连接器两种部署模式详解 4,重磅:如何玩转kylin

    1.6K100发布于 2018-01-31
  • 来自专栏星流全栈

    Phoenix Framework — 新一代的实时 Web 框架

    Jose Valim - Phoenix a web framework for the new web (Lambda Days 2016) 这是Elixir语言的设计者,Phoenix框架的主要贡献者 Jose Valim对于Phoenix框架的介绍视频。 Phoenix是一款使用Elixir编写的Web开发框架。它实现了服务端的MVC架构。它的许多组件和概念类似于我们常见的框架如Django和Ruby on Rails。 Phoenix提供了开发和生成环境的最佳实践,即高生产效率和高应用性能。它同时也有一些有趣的特性,如使用channels来实现实时特性和预编译的模板。

    2.6K50发布于 2018-06-01
  • 来自专栏python3

    python连接phoenix

    1.方案 这里我们通过Jpype和JayDeBeApi 来连接 2.过程 这里我列出实例代码: import jpype import jaydebeapi import os phoenix_client_jar ="/data/users/huser/phoenix/phoenix-4.3.0-client.jar" args=='-Djava.class.path=%s'% phoenix_client_jar jvm_path=jpype.getDefaultJVMPath() jpype.startJVM(jvm_path,args) conn=jaydebeapi.connect('org.apache.phoenix.jdbc.PhoenixDriver ',['jdbc:phoenix:bj-g2hdp1,bj-g2hdp2,bj-g2hdp3:2181','',''],phoenix_clinent_jar) curs=conn.cursor() sql

    1.4K20发布于 2020-01-03
  • 来自专栏文渊之博

    phoenix 索引实践

    SLF4J: Found binding in [jar:file:/opt/cloudera/parcels/CDH-5.12.1-1.cdh5.12.1.p0.3/jars/phoenix-4.14.0 /CDH-5.12.1-1.cdh5.12.1.p0.3/jars/slf4j-log4j12-1.7.5.jar! /org/slf4j/impl/StaticLoggerBinder.class] SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings first=0\x0010\x00\xE4\xB8\x9A\xE4\xB8\xBB\x000\x000\x0010\x000\x00\xE6\xAD\xA3\xE5\xB8\xB8\xE4\xB8\x9A xB8\x8D\xE4\xBA\xA4\xE7\x89\xA9\xE4\xB8\x9A\xE7\xAE\xA1\xE7\x90\x86\xE8\xB4\xB9\x00988.56\x000\x001\x004

    1.5K30发布于 2020-06-19
  • 来自专栏开源心路

    Phoenix 批量增加

    1.phoenix 利用CsvBulkLoadTool 批量带入数据并自动创建索引 在phoenix 目录下执行 hadoop jar /home/phoenix-4.6.0-HBase-1.0-bin /phoenix-4.6.0-HBase-1.0-client.jar   org.apache.phoenix.mapreduce.CsvBulkLoadTool -t POPULATION -i / 2.phoenix 自带sql导入工具 . try { read("F:/xxx/ico.sql"); } catch (Exception e) { e.printStackTrace(); } } } 插入两千万条数据用时一个小时 4. sqoop 工具,数据导入hbase,映射Phoenix中,关系型数据库的数值类型到hbase中变成字节类型,映射到phoenix中,数值类型数据值改变了

    73310编辑于 2023-06-29
  • 来自专栏Debug客栈

    Phoenix框架 从0到1设计业务并发框架 怎么组织设计一个框架

    上篇文章主要讲了设计 Phoenix 框架前的遇到的问题和设计框架的思路 《 Phoenix 框架 从0到1设计业务并发框架 小米商城产品站革新之路》,本篇文章主要讲一下如何设计框架的。 不死鸟并发框架,是自动构建有向图按照深度进行构建并发组并进行并发调用结果的框架。 名词解释PhoenixFramework 不死鸟(凤凰)框架,此业务并发框架的名称;Task 在业务并发中定义一次调用,可以是 HTTP、DUBBO 或者是 Redis 获取、MySQL 读库操作;Transfer ,框架的设计主要的是要思考如何将实际业务中使用的模块抽象化设计,同时要思考框架的扩展性与强约束性。 结尾本篇文章主要讲解我如何将业务与调用关系进行抽象成 Trans 与 Task 的,接下来我将讲述并发框架并发线程池的核心设计、配置化思考、监控设计以及自动构建算法等系列文章。

    27000编辑于 2024-03-19
  • 来自专栏Hadoop数据仓库

    基于 HBase & Phoenix 构建实时数仓(3)—— Phoenix 安装

    节点 进程 node1 node2 node3 node4 Phoenix * * * * 二、Phoenix 安装 在所有节点上执行下面第1、2步操作,在 node1 节点上执行第3 重启 HBase 集群 stop-hbase.sh start-hbase.sh 4. | | | | value4 | | | row5 | | | | | value5 | > upsert into "test" values('a','1','2','3','4','5'); 1 row affected (0.007 seconds) 0: jdbc:phoenix: | | | | value4 | | | row5 | | | | | value5 |

    98510编辑于 2024-03-09
  • 来自专栏Debug客栈

    Phoenix框架 从0到1设计业务并发框架 小米商城产品站革新之路

    小米商城产品站之前由于历史原因,存在着诸多问题与不便,随着技术的快速变革,技术部中台化的建设,越来越不适用于现在快速迭代的业务需求,接下来我将以技术的视角讲解我们遇到的痛点,以及解决这些痛点的思路,也就是 Phoenix 框架诞生的故事。 我调研发现业界 LiteFlow 框架是最受欢迎与好评的框架,于是在 Github 上面去了解框架底层实现的细节,随着深入阅读源码,发现这款框架设计的是真的很优秀,但是也过于庞大、复杂,特别是 EL 规则的写法 ,也就是 Phoenix Framework。 Phoenix,最初在周志明老师的网站"凤凰架构"提及,一方面是对周老师的架构设计理解与 Java 相关知识学习的致敬,另一方面,Phoenix 不死鸟,软件的生命周期也是如此,随着业务的快速发展诞生、

    35121编辑于 2024-03-08
  • 来自专栏Debug客栈

    Phoenix框架 从0到1设计业务并发框架 并发线程池的核心设计

    背景从 0 到 1 设计业务并发框架系列:Phoenix 框架 小米商城产品站革新之路Phoenix 框架 怎么组织设计一个框架前两篇文章已经讲述了我设计框架的背景以及抽象设计的细节,今天讲一下并发框架最为关键的并发线程池的核心设计 TaskA 并没有执行完毕,之后第二波流量进来:- 第 1 波流量开始执行 TaskC 和 TaskD;- 第 2 波流量进来,也有 TaskA 和 TaskB 获取到线程执行;T3 时刻,此时已经有 4 TaskD;- 第 1 波流量存在 TaskC 执行完,陆续开始执行线程池 3 的线程 TaskE;- 第 2 波流量进来,也有 TaskA 和 TaskB 获取到线程执行;T3 时刻,此时已经有 4 这个版本作为线上生产环境的第一个版本推了上去,单台 8C 8G (k8s) 的配置空跑框架达到了 QPS 在 1.4w,接口可用性在 99.96%(结果仅供参考,根据公司集群部署策略、机器性能等问题会有浮动 写在最后本篇文章主要讲框架设计中怎么将划分好的分层并发执行,最终我们采用了独立线程池的方案,并且按照耗时、CPU 核数等权重评估分配每个 Task 任务线程池的大小,让 CPU 线程调度来确保线程都尽可能的公平执行到

    38521编辑于 2024-04-07
  • 来自专栏后台技术底层理解

    Phoenix的使用

    quit退出 (2)创建表 create table hbase_test ( s1 varchar not null primary key, s2 varchar, s3 varchar, s4 varchar 在phoenix数据库层中所有的命令最好大写,最终会把所有的字符转化为大写字符,创建数据表的名称,列族可以使用引号括住,保证其不被强制转化为大写。 (4)删除 delete from hbase_test where s1='1'; (删除是按rowkey) (5)查询 select * from hbase_test where s1='1'; (6)批量导入数据bulkload 默认情况下,直接在hbase中创建的表,通过phoenix是查看不到的 如果需要在phoenix中操作直接在hbase中创建的表,则需要在phoenix中进行表的映射 表映射的话,在phoenix中的表与hbase中的表会被同时删除与修改,视图映射中的表删除,hbase中的表不会被删除。

    1.2K20发布于 2020-08-05
  • 来自专栏学习内容

    HBase整合Phoenix

    一、简介 1、Phoenix定义 1)官网地址:http://phoenix.apache.org/ Phoenix是HBase的开源SQL皮肤。 /my_env.sh 添加内容 #phoenix export PHOENIX_HOME=/opt/module/phoenix export PHOENIX_CLASSPATH=$PHOENIX_HOME PreparedStatement preparedStatement = connection.prepareStatement("select * from student"); // 4. PreparedStatement preparedStatement = connection.prepareStatement("select * from student"); // 4. 创建携带其他字段的全局索引 CREATE INDEX my_index ON my_table (v1) INCLUDE (v2); 4、本地索引(local index) Local Index适用于写操作频繁的场景

    86310编辑于 2023-12-04
  • 来自专栏Hadoop数据仓库

    基于 HBase & Phoenix 构建实时数仓(4)—— Kafka 集群安装部署

    节点 进程 node1 node2 node3 node4 Kafka * * * 二、安装部署 Kafka 集群 1. 分发相关目录到其它节点 scp -r $KAFKA_HOME node3:/root scp -r $KAFKA_HOME node4:/root 4. # 修改两个配置项 broker.id=2 listeners=PLAINTEXT://node4:9092 三. 4. 单纯从这两个命令行工具的测试结果看,消费者性能比生产者高 3-4 倍,不可能产生消费延迟。

    48710编辑于 2024-03-12
  • 来自专栏大数据杂货铺

    Phoenix常见问题

    查找有关Apache Phoenix及其部署的常见问题的答案。 01 Phoenix可以用于ETL用例吗? 是。 典型的Phoenix部署具有以下特点: • 应用 • Phoenix Client / JDBC驱动程序 • HBase客户端 Phoenix客户端/ JDBC驱动程序本质上是一个Java库,您应该在 但是,Phoenix的抽象尚未完成,例如,为了实现访问控制,您需要在包含Phoenix数据的基础HBase表上设置ACL。 ? 03 是否有Phoenix JDBC服务器的大小调整准则? Phoenix在全局索引维护期间执行本地索引以防止死锁:Phoenix还会在索引更新失败时部分地自动重建索引(PHOENIX-1112 )。 07 序列在Phoenix中如何工作? 数据是由Phoenix编码的,因此您必须对数据进行解码才能读取。直接写入HBase表会导致Phoenix损坏。 11 我可以在现有的HBase表上映射Phoenix表吗?

    1.6K30发布于 2020-10-29
  • 来自专栏大数据杂货铺

    FAQ系列之Phoenix

    查找有关 Apache Phoenix 及其部署的常见问题解答。 Phoenix 可以用于 ETL 用例吗? 是的。 Phoenix 在全局索引维护期间执行本地索引以防止死锁。:当索引更新失败时,Phoenix 还会部分自动重建索引 ( PHOENIX-1112 )。 序列如何在Phoenix工作? 我可以在 Phoenix 中进行批量数据加载吗? 是的,您可以在 Phoenix 中进行批量插入。 是的,只要使用 Phoenix 数据类型。您必须使用异步索引并手动更新它们,因为 Phoenix 不会知道任何更新。 Phoenix JDBC URL 语法是什么? 从 Phoenix 2.1 版开始,Phoenix 支持对可变和不可变数据进行索引。请注意,Phoenix 2.0.x 仅支持对不可变数据进行索引。

    4.2K30发布于 2021-07-27
  • 来自专栏开源心路

    phoenix删除数据

    操作过程: 第一步删除phoenix中系统的表格信息,主要为SYSTEM.CATALOG,第二步删除Hbase中的表格信息。 操作步骤: (1)查询phoenix系统表  SYSTEM.CATALOG 内容是所有表格的信息,系统表和自建表 SYSTEM.FUNCTION 内容是所有函数信息,系统函数和自定义函数 SYSTEM.SEQUENCE SYSTEM.CATALOG表结构  (3)我要删除的表格  DELETE from SYSTEM.CATALOG where TABLE_NAME = ‘USER_DETAILS’;  (4

    56110编辑于 2023-06-29
  • 来自专栏迹_Jason的AppZone

    Vertx-Phoenix实践

    前言 Vertx Vertx是一个高效的异步框架,支持Java、Scala、JavaScript、Kotlin等多种语言。 Phoenix 大数据的同学肯定对其很了解,是Apache基金会下的顶级工程,Phoenix帮助Hbase提供了SQL语法的支持,让难用的Hbase变得简单易用。 现状 使用HBase作为数据的持久化 场景对接口的TPS要求比较高 操作方式简单 问题与方案 Hbase是一种很好的大数据存储方案,但是其不支持SQL化操作,在开源解决方案中提供了Phoenix方案,文档和社区都比较活跃 实现 只对涉及Phoenix方面进行讲解,通过Scala进行编写 依赖Pom <dependency> <groupId>io.vertx</groupId> <artifactId </groupId> <artifactId>phoenix-core</artifactId> <version>4.13.1-HBase-1.3</version> </dependency

    1.1K30发布于 2019-05-29
  • 来自专栏有困难要上,没有困难创造困难也要上!

    使用phoenix查询hbase

    下载安装 首先从 apache 下载 phoenix 包,这里因为我的hbase hbase-1.4.9 版,所以我下载的对应的版本 apache-phoenix-4.14.1-HBase-1.4-bin.tar.gz 下载后解压之 apache-phoenix-4.14.1-HBase-1.4-bin.tar.gz tar zxvf apache-phoenix-4.14.1-HBase-1.4-bin.tar.gz 准备 hbase 为了使用 phoenix,需要将 phoenix 目录下的 phoenix-*。 jar 包复制到 hbase 的 lib 目录下,比如: cp apache-phoenix-4.14.1-HBase-1.4-bin/phoenix-*.jar hbase-1.4.9/lib/ 然后重新系统 /start-hbase.sh 连接phoenix 可以使用下面两种方式连接 方式一:直接连接 cd apache-phoenix-4.14.1-HBase-1.4-bin/bin # 默认连接本地hbase

    4.2K40发布于 2019-03-11
  • 来自专栏性能与架构

    Phoenix - Hbase与SQL

    Phoenix是什么 简单来说,Phoenix 是一个可以让我们通过SQL的方式操作HBase数据库的框架。 使用Phoenix的话,就可以使用SQL来查询,便捷高效,同时还可以为HBase添加二级索引,提升查询性能,还有其他一些方便的特性。 Phoenix 支持通过编写JDBC代码来操作HBase,比原生API更方便。 查询表数据: 0: jdbc:phoenix:localhost> select * from WEB_STAT; ? CORE、DB字段是CPU和数据库使用量。 小结 Phoenix 的基础功能就是在 HBase 之上添加了 SQL 层,可以让我们更方便的使用 HBase。

    1.3K60发布于 2018-04-04
  • 来自专栏Debug客栈

    Phoenix框架 从0到1设计业务并发框架 自动构建有向无循环图设计

    从 0 到 1 设计业务并发框架系列:Phoenix 框架 小米商城产品站革新之路Phoenix 框架 怎么组织设计一个框架Phoenix 框架 并发线程池的核心设计Phoenix 自动构建有向无环图的业务并发框架 ,首先定义好 Builder 的实现方式,如下:/** * @author debuginn */public interface PhoenixBuilder { // 过滤 Phoenix Task 是否存在相互依赖或循环依赖;将每个 API 收集上来的 Task 按照先后依赖关系进行分组划分;打印并发分组信息,用来给开发者调试及校验使用;由于存在依赖关系,需要进行分层设计,这里可以结合 Phoenix 框架 怎么组织设计一个框架 来看,然而每一层并不需要关系执行的顺序问题,这里采用了最简单的数据结构存储分层信息,Map<String, ArrayList<ArrayList<TaskObj>>> Key 不仅这里,Phoenix 框架尽可能的采用策略模式实现,将核心功能点都进行拆分,做到模块化设计,这样的设计正是 Phoenix 框架的设计初衷,生生不息,持续迭代。

    39321编辑于 2024-05-13
领券