File tree Expand file tree Collapse file tree 3 files changed +7
-7
lines changed Expand file tree Collapse file tree 3 files changed +7
-7
lines changed Original file line number Diff line number Diff line change 26
26
# Define table sources here. See the Table API & SQL documentation for details.
27
27
28
28
catalogs :
29
- - name : hcat
29
+ - name : hive
30
30
type : hive
31
31
property-version : 1
32
32
hive-version : 2.3.6
Original file line number Diff line number Diff line change 2
2
3
3
* What do we show in this demo
4
4
* 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
6
6
* Batch/Stream unification of queries in action
7
7
* Different ways to join dynamic data
8
8
* Creating Tables with DDL
@@ -90,7 +90,7 @@ SELECT * FROM prod_orders;
90
90
All static (MySQL-backed) tables are in the Hive catalog:
91
91
92
92
```
93
- USE CATALOG hcat ;
93
+ USE CATALOG hive ;
94
94
SHOW TABLES;
95
95
DESCRIBE prod_nation;
96
96
SELECT * FROM prod_nation;
@@ -314,7 +314,7 @@ SELECT
314
314
rs_rate AS `cur_rate`,
315
315
(l_extendedprice * (1 - l_discount) * (1 + l_tax)) / rs_rate AS `open in euro`
316
316
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
318
318
WHERE
319
319
l_linestatus = 'O' AND
320
320
l_currency = 'USD';
@@ -475,7 +475,7 @@ docker-compose exec kafka kafka-console-consumer.sh --bootstrap-server kafka:909
475
475
* We would like to store and mainain the result of the following query in MySQL.
476
476
477
477
```
478
- USE CATALOG hcat ;
478
+ USE CATALOG hive ;
479
479
```
480
480
481
481
```
Original file line number Diff line number Diff line change 1
- USE CATALOG hcat ;
1
+ USE CATALOG hive ;
2
2
3
3
CREATE TABLE prod_region (
4
4
r_regionkey INTEGER ,
@@ -66,4 +66,4 @@ CREATE TABLE prod_rates (
66
66
' connector.lookup.cache.ttl' = ' 0s'
67
67
);
68
68
69
- QUIT;
69
+ QUIT;
You can’t perform that action at this time.
0 commit comments