Transaktionstabellen mit Dataproc Metastore verwenden

Transaktionen mit ACID-Semantik werden von Apache Hive-Metastoren in Dataproc Metastore unterstützt. Weitere Informationen finden Sie unter Hive-Transaktionen. Diese Transaktionen sind in Hive 3 standardmäßig aktiviert.

Konfigurationen

Sie müssen server- und clientseitige Konfigurationen festlegen, um die Unterstützung von Transaktionen zu aktivieren.

Serverseitige Konfigurationen

Die folgenden serverseitigen Konfigurationen werden beim Erstellen des Dienstes durch Dataproc Metastore standardmäßig festgelegt. Sie können diese überschreiben, indem Sie unter Metastore-Konfigurationsüberschreibungen die Überschreibungen Key und Value eingeben.

metastore.compactor.initiator.on: Gibt an, ob der Initiator und die Bereinigungsthreads im Dataproc Metastore-Dienst ausgeführt werden sollen.

Legen Sie true fest, um den Initiator zu aktivieren.
metastore.compactor.worker.threads: Die Anzahl der Compactor-Worker-Threads, die im Dataproc-Metastore ausgeführt werden sollen.

Geben Sie eine positive Zahl an, um den Verdichter zu aktivieren. Eine höhere Zahl kann sich auf die Leistung des Dienstes auswirken, insbesondere wenn Sie sich auf der Entwicklerstufe befinden. Wenn diese Zahl angepasst werden muss, empfehlen wir die Verwendung eines niedrigeren Werts, z. B. 8.
hive.metastore.event.db.notification.api.auth: Gibt an, ob der Dataproc Metastore-Dienst die APIs für Datenbankbenachrichtigungen autorisieren sollte.

Legen Sie false fest. Wenn true festgelegt ist, haben nur die Superuser in den Proxy-Einstellungen die Berechtigung. Weitere Informationen zur Superuser-Proxy-Berechtigung finden Sie unter Sicherheit der Metastore Notification API.

Clientseitige Konfigurationen

Clientseitige Konfigurationen werden im Hive-Client festgelegt, wie unter Transaktionen validieren beschrieben.

hive.support.concurrency: Legen Sie hierfür den Wert true fest, um Transaktionen zum Einfügen, Aktualisieren und Löschen zu unterstützen.
hive.exec.dynamic.partition.mode: Im strikten Modus müssen Sie mindestens eine statische Partition für den Fall angeben, dass alle Partitionen versehentlich überschrieben werden. Im nicht strikten Modus dürfen alle Partitionen dynamisch sein.

Legen Sie hierfür den Wert nonstrict fest, um Transaktionen zum Einfügen, Aktualisieren und Löschen zu unterstützen.
hive.txn.manager: Legen Sie hierfür den Wert org.apache.hadoop.hive.ql.lockmgr.DbTxnManager fest.

Transaktionen validieren

Sie können Hive-Transaktionen mit einem Dataproc-Cluster validieren, der einen Dataproc Metastore-Dienst für Hive 3 verwendet.

Sie müssen den Dataproc-Cluster im selben Projekt wie den Dataproc Metastore-Dienst und mit Hive 3 erstellen. Die Dataproc 2.0-Images (2.0-Ubuntu18 und 2.0-debian10) unterstützen Hive 3 und Transaktionen. Mit dem Flag --image-version können Sie das 2.0-Image festlegen. Beispiel:

gcloud dataproc clusters create DATAPROC_CLUSTER_ID \
   --dataproc-metastore=projects/PROJECT_ID/locations/LOCATION/services/SERVICE \
   --region=REGION \
   --image-version 2.0-debian10

In der folgenden Anleitung wird gezeigt, wie Sie Transaktionen in Ihrem Dataproc Metastore-Dienst validieren, der von einem Dataproc-Cluster verwendet wird.

Stellen Sie eine SSH-Verbindung zum Dataproc-Cluster her. Dies ist über einen Browser oder über die Befehlszeile möglich.
Führen Sie den Befehl hive aus, um den Hive-Client zu öffnen:
```
$> hive
```

Richten Sie die clientseitigen Konfigurationen ein, um die Hive-ACID-Unterstützung für Transaktionen in der Hive-Clientsitzung zu aktivieren.

SET hive.txn.manager=org.apache.hadoop.hive.ql.lockmgr.DbTxnManager;
SET hive.support.concurrency=true;
SET hive.exec.dynamic.partition.mode=nonstrict;

Erstellen Sie eine Transaktionstabelle zum Einfügen und Aktualisieren von Daten. Folgendes ist ein Beispiel.
1. Erstellen Sie eine Transaktionstabelle:
```
create table student (id int, name string, age int)
STORED AS ORC TBLPROPERTIES ('transactional' = 'true');
```
2. Prüfen Sie, ob die Tabelle transaktional ist.
```
describe formatted <tableName>;
```
  Eine Liste der Tabelleneigenschaften wird gedruckt. Die Tabellenparameter einer Transaktionstabelle enthalten transactional=true.
3. So fügen Sie Daten in die Tabelle ein:
```
INSERT INTO student VALUES
(1, 'Alice', 10),
(2, 'Bob', 10),
(3, 'Charlie', 10);
```
  1. Beobachten Sie den Deltaordner, der im Verzeichnis student des Warehouse-Verzeichnisses des Dienstes erstellt wurde. Wenn Sie mehrere Insert- oder Update-Anweisungen ausführen, werden mehrere Deltaordner erstellt.
4. Sehen Sie sich an, welche Komprimierungen gerade ausgeführt werden und welchen Status sie haben. Hive-Metastore führt alle fünf Minuten einen Thread mit dem Namen Initiator aus, um nach Tabellen zu suchen, die verdichtet werden müssen, und fordert die Verdichtung für diese Tabellen an.
```
show compactions;
```
  1. So legen Sie eine manuelle Komprimierung fest: entweder klein oder groß.
```
  ALTER TABLE student COMPACT 'minor';
  ALTER TABLE student COMPACT 'major';
```