HBase - Client API
In diesem Kapitel wird die Java-Client-API für HBase beschrieben, die für die Ausführung verwendet wird CRUDOperationen auf HBase-Tabellen. HBase ist in Java geschrieben und verfügt über eine Java Native API. Daher bietet es programmgesteuerten Zugriff auf Data Manipulation Language (DML).
Klassen-HBase-Konfiguration
Fügt einer Konfiguration HBase-Konfigurationsdateien hinzu. Diese Klasse gehört zurorg.apache.hadoop.hbase Paket.
Methoden und Beschreibung
S.No. | Methoden und Beschreibung |
---|---|
1 | static org.apache.hadoop.conf.Configuration create() Diese Methode erstellt eine Konfiguration mit HBase-Ressourcen. |
Klasse HTable
HTable ist eine interne HBase-Klasse, die eine HBase-Tabelle darstellt. Es ist eine Implementierung einer Tabelle, die zur Kommunikation mit einer einzelnen HBase-Tabelle verwendet wird. Diese Klasse gehört zurorg.apache.hadoop.hbase.client Klasse.
Konstruktoren
S.No. | Konstruktoren und Beschreibung |
---|---|
1 | HTable() |
2 | HTable(TableName tableName, ClusterConnection connection, ExecutorService pool) Mit diesem Konstruktor können Sie ein Objekt erstellen, um auf eine HBase-Tabelle zuzugreifen. |
Methoden und Beschreibung
S.No. | Methoden und Beschreibung |
---|---|
1 | void close() Gibt alle Ressourcen der HTable frei. |
2 | void delete(Delete delete) Löscht die angegebenen Zellen / Zeilen. |
3 | boolean exists(Get get) Mit dieser Methode können Sie die Existenz von Spalten in der Tabelle testen, wie von Get angegeben. |
4 | Result get(Get get) Ruft bestimmte Zellen aus einer bestimmten Zeile ab. |
5 | org.apache.hadoop.conf.Configuration getConfiguration() Gibt das von dieser Instanz verwendete Konfigurationsobjekt zurück. |
6 | TableName getName() Gibt die Tabellennameninstanz dieser Tabelle zurück. |
7 | HTableDescriptor getTableDescriptor() Gibt den Tabellendeskriptor für diese Tabelle zurück. |
8 | byte[] getTableName() Gibt den Namen dieser Tabelle zurück. |
9 | void put(Put put) Mit dieser Methode können Sie Daten in die Tabelle einfügen. |
Klasse Put
Diese Klasse wird verwendet, um Put-Operationen für eine einzelne Zeile auszuführen. Es gehört zu denorg.apache.hadoop.hbase.client Paket.
Konstruktoren
S.No. | Konstruktoren und Beschreibung |
---|---|
1 | Put(byte[] row) Mit diesem Konstruktor können Sie eine Put-Operation für die angegebene Zeile erstellen. |
2 | Put(byte[] rowArray, int rowOffset, int rowLength) Mit diesem Konstruktor können Sie eine Kopie des übergebenen Zeilenschlüssels erstellen, um lokal zu bleiben. |
3 | Put(byte[] rowArray, int rowOffset, int rowLength, long ts) Mit diesem Konstruktor können Sie eine Kopie des übergebenen Zeilenschlüssels erstellen, um lokal zu bleiben. |
4 | Put(byte[] row, long ts) Mit diesem Konstruktor können wir eine Put-Operation für die angegebene Zeile unter Verwendung eines bestimmten Zeitstempels erstellen. |
Methoden
S.No. | Methoden und Beschreibung |
---|---|
1 | Put add(byte[] family, byte[] qualifier, byte[] value) Fügt der Put-Operation die angegebene Spalte und den angegebenen Wert hinzu. |
2 | Put add(byte[] family, byte[] qualifier, long ts, byte[] value) Fügt die angegebene Spalte und den angegebenen Wert mit dem angegebenen Zeitstempel als Version zu dieser Put-Operation hinzu. |
3 | Put add(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value) Fügt die angegebene Spalte und den angegebenen Wert mit dem angegebenen Zeitstempel als Version zu dieser Put-Operation hinzu. |
4 | Put add(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value) Fügt die angegebene Spalte und den angegebenen Wert mit dem angegebenen Zeitstempel als Version zu dieser Put-Operation hinzu. |
Klasse Get
Diese Klasse wird verwendet, um Get-Operationen für eine einzelne Zeile auszuführen. Diese Klasse gehört zurorg.apache.hadoop.hbase.client Paket.
Konstrukteur
S.No. | Konstruktor und Beschreibung |
---|---|
1 | Get(byte[] row) Mit diesem Konstruktor können Sie eine Get-Operation für die angegebene Zeile erstellen. |
2 | Get(Get get) |
Methoden
S.No. | Methoden und Beschreibung |
---|---|
1 | Get addColumn(byte[] family, byte[] qualifier) Ruft die Spalte aus der bestimmten Familie mit dem angegebenen Qualifikationsmerkmal ab. |
2 | Get addFamily(byte[] family) Ruft alle Spalten aus der angegebenen Familie ab. |
Klasse löschen
Diese Klasse wird verwendet, um Löschvorgänge für eine einzelne Zeile auszuführen. Um eine ganze Zeile zu löschen, instanziieren Sie ein Löschobjekt mit der zu löschenden Zeile. Diese Klasse gehört zurorg.apache.hadoop.hbase.client Paket.
Konstrukteur
S.No. | Konstruktor und Beschreibung |
---|---|
1 | Delete(byte[] row) Erstellt einen Löschvorgang für die angegebene Zeile. |
2 | Delete(byte[] rowArray, int rowOffset, int rowLength) Erstellt einen Löschvorgang für die angegebene Zeile und den angegebenen Zeitstempel. |
3 | Delete(byte[] rowArray, int rowOffset, int rowLength, long ts) Erstellt einen Löschvorgang für die angegebene Zeile und den angegebenen Zeitstempel. |
4 | Delete(byte[] row, long timestamp) Erstellt einen Löschvorgang für die angegebene Zeile und den angegebenen Zeitstempel. |
Methoden
S.No. | Methoden und Beschreibung |
---|---|
1 | Delete addColumn(byte[] family, byte[] qualifier) Löscht die neueste Version der angegebenen Spalte. |
2 | Delete addColumns(byte[] family, byte[] qualifier, long timestamp) Löscht alle Versionen der angegebenen Spalte mit einem Zeitstempel, der kleiner oder gleich dem angegebenen Zeitstempel ist. |
3 | Delete addFamily(byte[] family) Löscht alle Versionen aller Spalten der angegebenen Familie. |
4 | Delete addFamily(byte[] family, long timestamp) Löscht alle Spalten der angegebenen Familie mit einem Zeitstempel, der kleiner oder gleich dem angegebenen Zeitstempel ist. |
Klassenergebnis
Diese Klasse wird verwendet, um ein einzelnes Zeilenergebnis einer Get- oder Scan-Abfrage abzurufen.
Konstruktoren
S.No. | Konstruktoren |
---|---|
1 | Result() Mit diesem Konstruktor können Sie ein leeres Ergebnis ohne KeyValue-Nutzdaten erstellen. Gibt null zurück, wenn Sie raw Cells () aufrufen. |
Methoden
S.No. | Methoden und Beschreibung |
---|---|
1 | byte[] getValue(byte[] family, byte[] qualifier) Diese Methode wird verwendet, um die neueste Version der angegebenen Spalte abzurufen. |
2 | byte[] getRow() Diese Methode wird verwendet, um den Zeilenschlüssel abzurufen, der der Zeile entspricht, aus der dieses Ergebnis erstellt wurde. |