Es-hbase-hbase-update-data

提供:Dev Guides
移動先:案内検索

HBase-Actualizar Datos

使用済みの実際のデータは、更新されたコマンドを実行するために使用されます。 パラエロ、ソロティネスクイーンセギールラミスマシンタクシスアンドメンシオナーエルヌエボヴァロールコモセミューエストラアコンティニュアス。

put ‘table name’,’row ’,'Column family:column name',’new value’

エル・ヌエヴォ・バロール・ダド・サスティトゥエ・エル・バロールの存在、ラ・アクチュアリティオン・デ・ラ・フィラ。

エジェプロ

Supongamos que hay una tabla en HBase llamado emp con los siguientes datos

hbase(main):003:0> scan 'emp'
 ROW              COLUMN+CELL
row1 column=personal:name, timestamp=1418051555, value=raju
row1 column=personal:city, timestamp=1418275907, value=Hyderabad
row1 column=professional:designation, timestamp=14180555,value=manager
row1 column=professional:salary, timestamp=1418035791555,value=50000
1 row(s) in 0.0100 seconds

El siguiente comando seactualizaráel valor de ciudad del empleado de nombre "Raju" a Delhi。

hbase(main):002:0> put 'emp','row1','personal:city','Delhi'
0 row(s) in 0.0400 seconds

タブラ・セ・ベ・デ・ラ・シギエンテ・マネラ・デス・ド・ドン・セ・プエデ・オブザーバー・ラ・シウダード・デ・ラジュ・ハ・シド・カンビアード「デリー」

hbase(main):003:0> scan 'emp'
  ROW          COLUMN+CELL
row1 column=personal:name, timestamp=1418035791555, value=raju
row1 column=personal:city, timestamp=1418274645907, value=Delhi
row1 column=professional:designation, timestamp=141857555,value=manager
row1 column=professional:salary, timestamp=1418039555, value=50000
1 row(s) in 0.0100 seconds

JavaのAPIを使用してデータを取得する

Puede actualizar los datos en una celda en concreto utilizando el * put()*método。 シガ・ロス・パソス・ケ・セ・インディカンは、タブラのセルラー・デ・ウナ・バロ・デ・ラ・セルラー・デ・ウナ・バクラー・デ・ラ・セルラー・デ・ア・アクチュアライザーに続きます

手順1:構成のクラスを作成する

構成の説明 HBaseは、構成の構成をアーカイブします。 中間構成のオブジェクトを作成します* create()メタデータの *HbaseConfiguration を継続的に実行します。

Configuration conf = HbaseConfiguration.create();

手順2:HTableのクラスをインスタンス化する

*HTable* 、HBaseのタブラ実装のテンプレート。 単独のHBaseタブラを使用して、共通のユーティリティを作成します。 インスタシアのクラスの概要、構成パラメータの設定、およびタブラコモのパラメーター設定。 継続的なHTableの共同編集の表。
HTable hTable = new HTable(conf, tableName);

手順3:Poner Claseのインスタンス化

HBaseのタブの挿入、el * add()métodoy susバリアント。 エステメトドは、 *poner 、por lo tanto crear una instancia de la poner clase queを永続化します。 Esta clase requiere el nombre de la fila que desea insertar los datos en formato de cadena。 継続的なコミュニティコミュニティコミュニティ

Put p = new Put(Bytes.toBytes("row1"));

手順4:Updateanセルラーの存在

El * add()métodode *Put は、挿入データの使用を追跡します。 バイト列を表す3マトリックスのバイト列、列柱を表す列(列列)、挿入列、敬意を表す列。 HBaseタブの中間の挿入および追加*連続(*)*方法を使用して、連続したミュータントを作成します。

p.add(Bytes.toBytes("coloumn family "), Bytes.toBytes("column
name"),Bytes.toBytes("value"));
p.add(Bytes.toBytes("personal"),
Bytes.toBytes("city"),Bytes.toBytes("Delih"));

手順5:タブラの守護者

必要なものは、次のように挿入されます。

hTable.put(p);

手順6:Cierre HTable Ejemplo

HBase、cierre la HTable を使用して、タブラのデータを閉じます。close()como se muestra acontinuación。

hTable.close();

特定のプログラムの完全な連続性を含んでいます。

import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.HTable;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.util.Bytes;

public class UpdateData{

   public static void main(String[] args) throws IOException
   {

     //Instantiating Configuration class
      Configuration config = HBaseConfiguration.create();

     //Instantiating HTable class
      HTable hTable = new HTable(config, "emp");

     //Instantiating Put class
     //accepts a row name
      Put p = new Put(Bytes.toBytes("row1"));

     //Updating a cell value
      p.add(Bytes.toBytes("personal"),
      Bytes.toBytes("city"),Bytes.toBytes("Delih"));

     //Saving the put Instance to the HTable.
      hTable.put(p);
      System.out.println("data Updated");

     //closing HTable
      hTable.close();
   }
}

連続したプログラムの比較プログラム。

$javac UpdateData.java
$java UpdateData

Lo siguiente debe ser el producto:

data Updated