hbase

2熱

1答えて

私は、別のサーバ上にあるHBaseテーブルからデータを取得するスパークジョブ（Scalaで書かれています）を持っています。これを行うには、まずHBaseContextを次のように作成します。 val hBaseContext:HBaseContext = new HBaseContext(sparkContext, HBaseConfiguration.create()) 私はspark-subm

0熱

1答えて

apache.hadoop.security.AccessControlException：許可が拒否されました

私はHbase.Iで一括アップロードをしようとしています。テキストファイルを読んで、そこからHfileを作成して、そのHfileをHbase.Allにロードしています。これは、仕事を減らす。私はHfileを作成することができます。また、/ _SUCCESSで出力ディレクトリを見ることもできます。しかし、Hbaseではデータを読み込むことができず、例外として以下のようになります。 hadoop.

0熱

1答えて

hbaseからの読み取り時にflink thowingシリアル化エラーが発生する

マップ内でrichfatMapFunctionを使用してhbaseから読み込むと、シリアル化エラーが発生します。私がしようとしているのは、datastreamがhbase else ignoreから読み取られた特定の文字列に等しい場合です。以下は、私が得ているサンプルプログラムとエラーです。 package com.abb.Flinktest import java.text.SimpleDat

0熱

1答えて

がどのようにHBaseの倹約のhbase_thrift.ttypes.TIOErrorを修正するには：TIOError（_message = "場所を取得できません"）私はPythonプログラムでHbase1.1.2とthrift2を使用

：この機能を実行する def scaner(self, numRows=2, columns=None, filterString=None): columns_list = self.create_columns(columns) scaner = TScan(columns=columns_list, filterString=filterString) scan

0熱

1答えて

hbaseのシステムでラベルを削除する方法はありますか？ HBaseので

、ユーザーはシェルで次のコマンドを使用して、システムにラベルを追加することができます。 add_labels ['one', 'two', three'] またはJAVA_APIで VisibilityClient.addLabels(...) 私の質問は、これらすべてのラベルを削除する可能性があるかどうかでありますシステムレベルで作成されますか？

0熱

1答えて

hbaseレンジスキャンの操作方法は？

私はrow1、row2、row3 ....とrowNのようなrowkeyを持つhbaseテーブルを持っています。私が望むのは、row100からrow200までのrowkeyを持つ行を取得する方法、クエリ節を書く方法、またはhbaseテーブルを作成する方法です。クエリは高速ですか？

1熱

1答えて

HBaseの行の接頭辞は、私は、フォームの行キーを持っているのHBase

に逆の順序でスキャンします。 scan 'mytable', {LIMIT => 15, ROWPREFIXFILTER => 'name' } は私の最初の15を与えるが、： scan 'mytable', {LIMIT => 15, REVERSED => TRUE, ROWPREFIXFILTER => 'name'} 戻り、結果をゼロに...そのような要求の構文はは何ですか？手

1熱

1答えて

Hbaseは重複レコードをどのように扱いますか？

Hbaseが内部的にファイルから重複レコードを処理する方法を理解したいと思います。これを実験するために、テーブルプロパティ、SERDE、列ファミリなどのHBase固有の構成プロパティを使用して、ハイブでEXTERNALテーブルを作成しました。 HBaseで列ファミリのテーブルを作成する必要があります。重複したレコードを持つソーステーブルからこのHIVEテーブルへの上書きを実行しました。私はこの

0熱

2答えて

300列ファミリのhbaseテーブルを作成しても問題ありませんか？

私はシナリオを持っています。各オブジェクトには300種類のバリアントがあります。そのため、それらをhbaseに保存し、元のオブジェクトと各列ファミリの300種類のバリアントを格納します。アクセスモデルは、毎朝バッチでオブジェクトをテーブルに挿入し、それを読み込もうとしています。私のシナリオでは、300列のファミリを持つhbaseテーブルを作成することは問題ありませんか？

0熱

1答えて

はHBaseのからデータを受け取り、私はこのようハイブ表を作成することができます

HBaseのテーブルから一部のデータを使用して外部ハイブテーブルを作成します。他は「レビュー」であり、_タイプのキーはそれがどのタイプのアイテムであるかを定義します。私は_type = 'review'と_type = 'app'を持つ行を取る他の行を取る同じhbaseテーブルからハイブで2つの別々の外部テーブルを作成したいと思います。これをどうやってやるの？