Skip to content

Commit ae18abf

Browse files
committed
Rename Hive catalog from hcat to hive
1 parent 6e56e3a commit ae18abf

File tree

3 files changed

+7
-7
lines changed

3 files changed

+7
-7
lines changed

client-image/conf/sql-client-conf.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626
# Define table sources here. See the Table API & SQL documentation for details.
2727

2828
catalogs:
29-
- name: hcat
29+
- name: hive
3030
type: hive
3131
property-version: 1
3232
hive-version: 2.3.6

demo_script.md

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
* What do we show in this demo
44
* Flink SQL processing data from different storage systems
5-
* Flink SQL using HCatalog as an external, persistent catalog
5+
* Flink SQL using Hive Metastore as an external, persistent catalog
66
* Batch/Stream unification of queries in action
77
* Different ways to join dynamic data
88
* Creating Tables with DDL
@@ -90,7 +90,7 @@ SELECT * FROM prod_orders;
9090
All static (MySQL-backed) tables are in the Hive catalog:
9191

9292
```
93-
USE CATALOG hcat;
93+
USE CATALOG hive;
9494
SHOW TABLES;
9595
DESCRIBE prod_nation;
9696
SELECT * FROM prod_nation;
@@ -314,7 +314,7 @@ SELECT
314314
rs_rate AS `cur_rate`,
315315
(l_extendedprice * (1 - l_discount) * (1 + l_tax)) / rs_rate AS `open in euro`
316316
FROM prod_lineitem
317-
JOIN hcat.`default`.prod_rates FOR SYSTEM_TIME AS OF l_proctime ON rs_symbol = l_currency
317+
JOIN hive.`default`.prod_rates FOR SYSTEM_TIME AS OF l_proctime ON rs_symbol = l_currency
318318
WHERE
319319
l_linestatus = 'O' AND
320320
l_currency = 'USD';
@@ -475,7 +475,7 @@ docker-compose exec kafka kafka-console-consumer.sh --bootstrap-server kafka:909
475475
* We would like to store and mainain the result of the following query in MySQL.
476476

477477
```
478-
USE CATALOG hcat;
478+
USE CATALOG hive;
479479
```
480480

481481
```

flinksql-init/create_tables.sql

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
USE CATALOG hcat;
1+
USE CATALOG hive;
22

33
CREATE TABLE prod_region (
44
r_regionkey INTEGER,
@@ -66,4 +66,4 @@ CREATE TABLE prod_rates (
6666
'connector.lookup.cache.ttl' = '0s'
6767
);
6868

69-
QUIT;
69+
QUIT;

0 commit comments

Comments
 (0)