草庐IT

phoenix-channels

全部标签

rest - 如何通过HBase REST服务获取Phoenix表数据

我在以下代码片段中使用PhoenixJDBC驱动程序创建了一个HBase表:Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");Connectionconn=DriverManager.getConnection("jdbc:phoenix:serverurl:/hbase-unsecure");System.out.println("gotconnection");conn.createStatement().execute("CREATETABLEIFNOTEXISTSphoenixtest(idBIGINTnotnullp

java - Phoenix 正在改变 HBase 表的元信息

我正在尝试使用ApachePhoenix在HBase表上运行SQL查询。基于officialdocumetation,需要使用SQL查询为现有表创建模式:CREATETABLETABLE_NAME(....)我试图通过phoenixAPI直接连接到现有表(使用HBaseAPI创建)来避免这种情况,但我遇到了异常。问题是当Phoenix执行这个查询时,它会在表上创建很多东西。例如,在hbase仪表板的tables部分,我可以看到phoenix添加到我的表中的以下元数据:'QUOTES',{METHOD=>'table_att',coprocessor$1=>'|org.apache.ph

java - 如何在hadoop和phoenix上运行web应用

我在ubuntu14中安装了hadoop、hbase和phoenix,并在eclipse中运行了一个连接phoenix的简单示例。它可以运行并执行我的查询。publicstaticvoidexecute()throwsClassNotFoundException{Connectionconnection=null;Statementstatement=null;ResultSetrs=null;PreparedStatementps=null;try{connection=DriverManager.getConnection("jdbc:phoenix:localhost");sta

hadoop - HDP : unable to start Phoenix sqlline. py

我正在使用SandboxHDP2.2我做了一个yuminstallphoenix(版本是4.2)但是当我运行这些时:./sqlline.pylocalhost:2181./sqlline.pylocalhost./sqlline.pysandbox.hortonworks.com:2181./sqlline.pysandbox.hortonworks.com我得到了错误:15/07/0308:26:31ERRORclient.ConnectionManager$HConnectionImplementation:Thenode/hbaseisnotinZooKeeper.Itshoul

hadoop - 在发送到 channel 之前删除空的 Flume 事件

我在Flume的一本书上看到,如果在拦截器的intercept方法中有一个事件返回为null,这个事件就会被丢弃。因此,我创建了一个自定义拦截器,它根据条件将事件返回为null,例如:publicEventintercept(Eventevent){//TODOAuto-generatedmethodstubEventfinalEvent=event;check=newString(event.getBody(),Charsets.UTF_8);if(check.matches("([0-9]-.+?-.+?-[0-9][0-9]+)")){try{fileWriter.append(

apache phoenix 加入查询性能

几个月前我开始使用phoenix。以下是环境和版本详细信息。Hadoop–ClouderaCDH5.4.7-1。Phoenix–4.3–Phoenix在CDH5.4.7-1上作为包裹出现。HBase版本–HBase1.0.0JDK——1.7.0_671个主服务器和3个区域服务器。我们开始做POC来评估ApachePhoenix。我们在OracleDB的12个不同表中有数据。我们使用Oraclegoldengate将数据导入Hadoop系统。有12个不同的Phoenix表,每个表有40-100列和几百行。我们进行转换过程,然后加载到最终表中。这是我们正在做的基本ETL。转换过程经历了几个

hadoop - 将数据帧写入 Phoenix

我正在尝试将Dataframe写入Phoenix表,但出现异常。这是我的代码:df.write.format("org.apache.phoenix.spark").mode(SaveMode.Overwrite).options(collection.immutable.Map("zkUrl"->"localhost:2181/hbase-unsecure","table"->"TEST")).save();异常(exception)情况是:org.apache.spark.SparkException:Jobabortedduetostagefailure:Task0instage

rabbitmq - 如何避免使用 amqp php、持久连接和 php-fpm 的每个 tcp 连接的最大 channel 数

我刚开始学习rabbitMQ,但遇到了一个问题。使用http://pecl.php.net/package/amqp版本1.4(最新版本)和RabbitMQ3.3.1。我们必须使用php5-fpm和带有amqp->pconnect()的持久连接。一段时间后(我猜是65500个请求)出现一个问题,停止所有写入"Couldnotcreatechannel.Connectionhasnoopenchannelslotsremaining”根据我在源代码中读到的内容,因为每个tcp连接都有一个达到其最大值的自动增量channelID。发生这种情况是因为每个请求都必须使用channel,并且无法

php - 安装 phpunit 中的问题 - 尝试回退到 https 而不是 channel phpunit 上的 http

我尝试在xampp中安装phpunit时遇到此错误。C:\xampp\php>pearinstall--alldepsphpunit/PHPUnitAttemptingtodiscoverchannel"phpunit"...Attemptingfallbacktohttpsinsteadofhttponchannel"phpunit"...unknownchannel"phpunit"in"phpunit/PHPUnit"invalidpackagename/packagefile"phpunit/PHPUnit"installfailed 最佳答案

php - youtube channel URL 的正则表达式

如何使用REGEX验证youtubechannelURL?我找到了这个模式,但它不能正常工作/((http|https):\/\/|)(www.|)youtube\.com\/(channel\/|user\/|)[a-zA-Z0-9]{1,}/谁能帮帮我? 最佳答案 您的问题是user\/之后的额外管道这是更正后的正则表达式:((http|https):\/\/|)(www\.|)youtube\.com\/(channel\/|user\/)[a-zA-Z0-9_-]{1,}这是一个问题的原因是它使(channel|user)成