[hotfix][doc] Fix minor error in hive_streaming.md

deepfield · Jun 15, 2020 · 5e43f01 · 5e43f01
1 parent 97fc6b3
commit 5e43f01
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/docs/dev/table/hive/hive_streaming.md b/docs/dev/table/hive/hive_streaming.md
@@ -75,8 +75,8 @@ SET table.sql-dialect=hive;
 CREATE TABLE hive_table (
  user_id STRING,
  order_amount DOUBLE
-) PARTITIONED BY (dt STRING, hour STRING) STORED AS parquet TBLPROPERTIES (
- 'partition.time-extractor.timestamp-pattern'='$dt $hour:00:00',
+) PARTITIONED BY (dt STRING, hr STRING) STORED AS parquet TBLPROPERTIES (
+ 'partition.time-extractor.timestamp-pattern'='$dt $hr:00:00',
  'sink.partition-commit.trigger'='partition-time',
  'sink.partition-commit.delay'='1 h',
  'sink.partition-commit.policy.kind'='metastore,success-file'
@@ -94,7 +94,7 @@ CREATE TABLE kafka_table (
 INSERT INTO TABLE hive_table SELECT user_id, order_amount, DATE_FORMAT(log_ts, 'yyyy-MM-dd'), DATE_FORMAT(log_ts, 'HH') FROM kafka_table;
 
 -- batch sql, select with partition pruning
-SELECT * FROM hive_table WHERE dt='2020-05-20' and hour='12';
+SELECT * FROM hive_table WHERE dt='2020-05-20' and hr='12';
 
 {% endhighlight %}
 

diff --git a/docs/dev/table/hive/hive_streaming.zh.md b/docs/dev/table/hive/hive_streaming.zh.md
@@ -75,8 +75,8 @@ SET table.sql-dialect=hive;
 CREATE TABLE hive_table (
  user_id STRING,
  order_amount DOUBLE
-) PARTITIONED BY (dt STRING, hour STRING) STORED AS parquet TBLPROPERTIES (
- 'partition.time-extractor.timestamp-pattern'='$dt $hour:00:00',
+) PARTITIONED BY (dt STRING, hr STRING) STORED AS parquet TBLPROPERTIES (
+ 'partition.time-extractor.timestamp-pattern'='$dt $hr:00:00',
  'sink.partition-commit.trigger'='partition-time',
  'sink.partition-commit.delay'='1 h',
  'sink.partition-commit.policy.kind'='metastore,success-file'
@@ -94,7 +94,7 @@ CREATE TABLE kafka_table (
 INSERT INTO TABLE hive_table SELECT user_id, order_amount, DATE_FORMAT(log_ts, 'yyyy-MM-dd'), DATE_FORMAT(log_ts, 'HH') FROM kafka_table;
 
 -- batch sql, select with partition pruning
-SELECT * FROM hive_table WHERE dt='2020-05-20' and hour='12';
+SELECT * FROM hive_table WHERE dt='2020-05-20' and hr='12';
 
 {% endhighlight %}