happybase

2热度

1回答

我在HBase中有一个表，其中汉字存储在某个列中，比如'FLT：CREW_DEPT'。现在我需要过滤出'FLT：CREW_DEPT'等于某个值的所有行。当HBase的壳这样做，它工作正常，如下图所示 scan 'PAX_EXP_FACT', {COLUMNS => ['FLT:CREW_DEPT'], FILTER => "SingleColumnValueFilter ('FLT', 'CREW

0热度

1回答

happybase table.scan中的row_prefix不能与str变量一起工作

我正在使用table.scan方法中的row_prefix来过滤行。问题是函数在使用字符串文字时工作。但是，如果使用变量，则不会返回任何数据。例如，下面的代码工作 connection = happybase.Connection(connect string) table = connection.table('table') table = table.scan(row_prefix='

0热度

1回答

Bigtable Google Happybase Python KeyError试图做`counter_inc`

我不知道为什么，但counter_inc方法不工作，没有模拟器，指向一个开发真实的实例。段： from google.cloud import bigtable from google.cloud import happybase client = bigtable.Client(project='robbie-ai', admin=True) instance = client.ins

2热度

1回答

HBase中的过滤器：设计用于按行或按列还是两者过滤数据？

我一直对HBase中的过滤器如何工作感到困惑（或者，大体上等同于HappyBase--我用它来与HBase进行交互）。我混乱的根源是，我似乎无法控制过滤器的功能。某些过滤器（如SingleColumnValueFilter）会导致不根据其某列的值排放行。这是有道理的 - 在我看来，这是过滤器应该是的。但是，像FirstKeyOnlyFilter这样的其他过滤器似乎不是按行方向进行过滤，而是过滤出

0热度

1回答

HappyBase - 不显示结果

想从使用HappyBase 这里蟒蛇连接到HBase的是我试图 >import happybase >connection = happybase.Connection(host = <myHost>,port = <myPort>) <happybase.connection.Connection object at 0x7ff46c527bd0> >connection.tabl

0热度

2回答

从Python和happybase/Thrift连接到Hbase

我已经安装了Cloudera Manager Express 5.9.0安装HBase，Thrift服务器在VirtualBox vm中的CentOS 7.3上的端口9090上运行。请帮助弄清楚为什么我无法通过happybase成功连接，或帮助确定下一步要追求的步骤。我是一名经验丰富的Java程序员，学习Python。我有使用本地接口从Java使用Hbase的经验，虽然不是在这个特定的环境中。

1热度

1回答

Happybase使用行筛选函数

我想对Happybase执行一个rows查询以获得一些已知的行键并添加值筛选器，以便只返回与筛选器匹配的行。在HBase的外壳可以提供一个过滤器，以获取命令，就像这样： get 'meta', 'someuser', {FILTER => "SingleColumnValueFilter ('cf','gender',=,'regexstring:^male$')"} 在Happybase您

0热度

1回答

在我的HBase主人上是节俭运行吗？如何与Happybase连接？

我在伪分布式模式下运行krejcmat/hadoop-hbase docker。这是主站和从站在同一台机器上运行在不同的容器中。开始Hadoop集群和HBase的后，我开始与主节点上的节俭服务器： hbase thrift start -threadpool 我也暴露节点9090（在开始默认节俭端口--expose=9090）。我想使用Happybase库从我的主机连接到通过Thrift AP

0热度

1回答

使用Scala将csv数据加载到Hbase

有没有办法使用scala将csv文件加载到hbase而无需使用spark？我正在寻找类似于Happybase的工具。

3热度

1回答

与HappyBase

更新HBase的数据我试图写一个函数从保存在HBase的表更新数据。我有一个将被调用，以更新其功能和我有一个很好的开始，但我是在完成它的最后一点点丧失。我可以到其他更新单行基于一个字符串，但比较日志时候，我似乎无法弄清楚如何做到这一点，因为没有设置日志时间。我将表中的所有值存储到字典中。这里是我的代码： def updateHBase(row): dict = row.asDict() #cr