hbase

0熱

2答えて

私はapache phoenixの値を更新する際に問題があります。以下のクエリはJDBC例外をスローしています。私はPheonix JDBCが新しく、非主キーフィールドの値を更新するためのアップサートクエリの使用法と混同しています。 String sql = UPSERT INTO mytable (serverName,SationName, product) SELECT serverName

1熱

1答えて

Apache Spark：チェックポイントから復旧中のNPE

HBase RDDを使用して着信DStreamと結合する簡単なStreamingアプリケーションを構築しています。サンプルコード： val indexState = sc.newAPIHadoopRDD( conf, classOf[TableInputFormat], classOf[ImmutableBytesWritable], classOf[Res

0熱

1答えて

HBase TimeoutIOException

私はsparkとscalaを使用してHBaseデータを取得しようとしています。しかし、私は熟考することができないエラーが発生しています。コード import org.apache.spark.{SparkConf, SparkContext} import org.apache.hadoop.hbase.HBaseConfiguration import org.apache.hadoop.

0熱

1答えて

SparkでGetコマンドを使用してHbaseからデータを読み取る

getコマンドを使用してHbaseテーブルからデータを読み込み、その行のキーも持っていたいと思います。私のSparkストリーミングアプリケーションでこれをやりたいです。誰かが共有できるコードですか？

1熱

1答えて

hbaseテーブルがbashスクリプトから存在するかどうかを確認する方法

hbaseテーブルが存在するかどうかをチェックする必要があるため、メッセージを出力する必要があるbashスクリプトがあります。以下は私が試みたものです。 doesTableExist=$(echo -e "exists '$base_table_name' | hbase shell") if [ $? -eq 0 ] then echo [BYOA_HIVE_INGEST] [I

0熱

1答えて

大量のデータを含むhbaseに対して除外する

大量のストリームを重複排除するためにhbaseを使用しています。私はそれが行キーとして使用するストリーム内の各メッセージから一意の識別子を使用してうまくいくと思った。しかし、エンドユーザーは、私が作成した出力ストリームから重複したデータを見ています。唯一の考えられる原因は、重複したメッセージが同時に消費されることです。私は約50のスレッドが別のプロセスでストリームからいっぱいになっている同じキュ

2熱

1答えて

doInTable（HTableInterfaceテーブル）は非推奨です

廃止予定のdoInTable（HTableInterfaceテーブル）の代わりに何が使えますか？以下はコードです。 hbaseTemplate.execute(tableName, new TableCallback<User>() { public User doInTable(HTableInterface table) throws Throwable { Put

0熱

1答えて

外部のハイブテーブルへのカウンタ列を持つhbaseテーブルのマッピング？

hbaseテーブルを表示するために、ハイブでテーブルをマップしようとしています。私はいくつかの列で問題なくこれを行いましたが、カウンタ列でどのように管理するのかは不明です。これは可能ですか？ hbaseテーブルをスキャンすると、カウンタ列の値の例は\x00\x00\x00\x00\x00\x00\x00\x01になります。ハイブテーブルで列の種類を誤って設定していると思われます。私はintとst

0熱

1答えて

HBase idを上書きする

がhbaseテーブルにのエントリを追加するとどうなりますか？列に更新されたタイムスタンプが表示されました。テーブルに追加する際に、を上書きすることを避ける/許可するオプションがあるhbaseにのプロパティがありますか？

2熱

1答えて

スパークストリーミング：ソースHBase

スパークストリーミングジョブをセットアップしてHBaseテーブルを追跡し、バッチごとに新しい/更新された行を読み取ることは可能ですか？ブログhereは、HDFSファイルがサポートされているソースの下に来ると言います。しかし、彼らは次の静的APIを使用しているようです： sc.newAPIHadoopRDD(..) 私はこれに関するドキュメントを見つけることができません。スパークストリーミングコ