Merge branch 'main' into bump

Author: mergify[bot]

Cargo.lock

@@ -30,6 +30,7 @@ members = [
     "src/query/functions-v2",
     "src/query/legacy-parser",
     "src/query/management",
+    "src/query/planner",
     "src/query/pipeline/core",
     "src/query/pipeline/sinks",
     "src/query/pipeline/sources",

Cargo.toml

@@ -2,7 +2,9 @@
 title: FUSE_BLOCK
 ---
 
-Returns the block information of a snapshot of table.
+Returns the block information for the latest or a specifed snapshot of a table. 
+
+The command returns the location information of each parquet file related to a snapshot. This enables downstream applications to access and consume the data stored in the files. 
 
 ## Syntax
 

docs/doc/30-reference/20-functions/111-system-functions/fuse_block.md

@@ -22,9 +22,9 @@ INSERT INTO mytable VALUES(4,4);
 SELECT * FROM FUSE_SNAPSHOT('default','mytable');
 
 ---
-| snapshot_id                      | snapshot_location                                          | format_version | previous_snapshot_id             | segment_count | block_count | row_count | bytes_uncompressed | bytes_compressed | timestamp                  |
-|----------------------------------|------------------------------------------------------------|----------------|----------------------------------|---------------|-------------|-----------|--------------------|------------------|----------------------------|
-| dd98266f968f4817b470255592d04fda | 670655/670675/_ss/dd98266f968f4817b470255592d04fda_v1.json | 1              | \N                               | 1             | 1           | 2         | 16                 | 290              | 2022-09-07 01:58:55.204997 |
-| 2f2d004ff6f842cdb25f5631b2bbb703 | 670655/670675/_ss/2f2d004ff6f842cdb25f5631b2bbb703_v1.json | 1              | dd98266f968f4817b470255592d04fda | 2             | 2           | 4         | 32                 | 580              | 2022-09-07 01:59:09.742999 |
-| 0aa6dfd5d5364bde80f21161ba48c96e | 670655/670675/_ss/0aa6dfd5d5364bde80f21161ba48c96e_v1.json | 1              | 2f2d004ff6f842cdb25f5631b2bbb703 | 3             | 3           | 5         | 40                 | 862              | 2022-09-07 01:59:16.858454 |
+| snapshot_id                      | snapshot_location                                          | format_version | previous_snapshot_id             | segment_count | block_count | row_count | bytes_uncompressed | bytes_compressed | index_size | timestamp                  |
+|----------------------------------|------------------------------------------------------------|----------------|----------------------------------|---------------|-------------|-----------|--------------------|------------------|------------|----------------------------|
+| a13d211b7421432898a3786848b8ced3 | 670655/783287/_ss/a13d211b7421432898a3786848b8ced3_v1.json | 1              | \N                               | 1             | 1           | 2         | 16                 | 290              | 363        | 2022-09-19 14:51:52.860425 |
+| cf08e6af6c134642aeb76bc81e6e7580 | 670655/783287/_ss/cf08e6af6c134642aeb76bc81e6e7580_v1.json | 1              | a13d211b7421432898a3786848b8ced3 | 2             | 2           | 4         | 32                 | 580              | 726        | 2022-09-19 14:52:15.282943 |
+| 1bd4f68b831a402e8c42084476461aa1 | 670655/783287/_ss/1bd4f68b831a402e8c42084476461aa1_v1.json | 1              | cf08e6af6c134642aeb76bc81e6e7580 | 3             | 3           | 5         | 40                 | 862              | 1085       | 2022-09-19 14:52:20.284347 |
 ```

docs/doc/30-reference/20-functions/111-system-functions/fuse_snapshot.md

@@ -2,11 +2,13 @@
 title: SHOW TABLE STATUS
 ---
 
-Shows the list of table status in the currently selected database.
+Shows the status of the tables in a database. The status information includes various physical sizes and timestamps about a table, see [Examples](#examples) for details. 
+
+The command returns status information of all the tables in the current database by default. Use a FROM | IN clause to specify another database rather than the current one. You can also filter tables with a LIKE or WHERE clause.
 
 ## Syntax
 
-```
+```sql
 SHOW TABLE STATUS
     [{FROM | IN} db_name]
     [LIKE 'pattern' | WHERE expr]
@@ -16,17 +18,19 @@ SHOW TABLE STATUS
 
 ```sql
 CREATE TABLE t(id INT);
-SHOW TABLE STATUS\G
+
+-- Show status of all tables in the current database
+SHOW TABLE STATUS;
 *************************** 1. row ***************************
            Name: t
          Engine: FUSE
         Version: 0
      Row_format: NULL
-           Rows: NULL
+           Rows: 0
  Avg_row_length: NULL
-    Data_length: NULL
+    Data_length: 0
 Max_data_length: NULL
-   Index_length: NULL
+   Index_length: 0
       Data_free: NULL
  Auto_increment: NULL
     Create_time: 2022-04-08 04:13:48.988 +0000
@@ -37,19 +41,20 @@ Max_data_length: NULL
         Comment:
 ```
 
-Showing the tables with table name `"t"`:
+The following returns status information of the table named "t":
+
 ```sql
-SHOW TABLE STATUS LIKE 't'\G
+SHOW TABLE STATUS LIKE 't';
 *************************** 1. row ***************************
            Name: t
          Engine: FUSE
         Version: 0
      Row_format: NULL
-           Rows: NULL
+           Rows: 0
  Avg_row_length: NULL
-    Data_length: NULL
+    Data_length: 0
 Max_data_length: NULL
-   Index_length: NULL
+   Index_length: 0
       Data_free: NULL
  Auto_increment: NULL
     Create_time: 2022-04-08 04:13:48.988 +0000
@@ -60,42 +65,44 @@ Max_data_length: NULL
         Comment:
 ```
 
-Showing the tables begin with `"t"`:
+The following uses a LIKE clause to return status information of the tables with a name starting with "t":
+
 ```sql
-SHOW TABLE STATUS LIKE 't%'\G
+SHOW TABLE STATUS LIKE 't%';
 *************************** 1. row ***************************
            Name: t
          Engine: FUSE
         Version: 0
      Row_format: NULL
-           Rows: NULL
+           Rows: 0
  Avg_row_length: NULL
-    Data_length: NULL
+    Data_length: 0
 Max_data_length: NULL
-   Index_length: NULL
+   Index_length: 0
       Data_free: NULL
  Auto_increment: NULL
     Create_time: 2022-04-08 04:13:48.988 +0000
     Update_time: NULL
      Check_time: NULL
       Collation: NULL
        Checksum: NULL
-        Comment: 
+        Comment:
 ```
 
-Showing the tables begin with `"t"` with `WHERE`:
+The following uses a WHERE clause to return status information of the tables with a name starting with "t":
+
 ```sql
-SHOW TABLE STATUS WHERE name LIKE 't%'\G
+SHOW TABLE STATUS WHERE name LIKE 't%';
 *************************** 1. row ***************************
            Name: t
          Engine: FUSE
         Version: 0
      Row_format: NULL
-           Rows: NULL
+           Rows: 0
  Avg_row_length: NULL
-    Data_length: NULL
+    Data_length: 0
 Max_data_length: NULL
-   Index_length: NULL
+   Index_length: 0
       Data_free: NULL
  Auto_increment: NULL
     Create_time: 2022-04-08 04:13:48.988 +0000
@@ -106,19 +113,20 @@ Max_data_length: NULL
         Comment:
 ```
 
-Showing the tables are inside `"default"`:
+The following returns status information of all tables in the database `default`:
+
 ```sql
-SHOW TABLE STATUS FROM 'default'\G
+SHOW TABLE STATUS FROM 'default';
 *************************** 1. row ***************************
            Name: t
          Engine: FUSE
         Version: 0
      Row_format: NULL
-           Rows: NULL
+           Rows: 0
  Avg_row_length: NULL
-    Data_length: NULL
+    Data_length: 0
 Max_data_length: NULL
-   Index_length: NULL
+   Index_length: 0
       Data_free: NULL
  Auto_increment: NULL
     Create_time: 2022-04-08 04:13:48.988 +0000
@@ -127,4 +135,4 @@ Max_data_length: NULL
       Collation: NULL
        Checksum: NULL
         Comment:
-```
+```

docs/doc/30-reference/30-sql/40-show/show-table-status.md

@@ -14,11 +14,10 @@
 
 use std::borrow::Cow;
 use std::collections::BTreeMap;
+use std::fmt;
 use std::fmt::Debug;
 use std::fmt::Display;
 use std::fmt::Formatter;
-use std::fmt::{self};
-use std::io::Write;
 use std::ops::Neg;
 
 use decimal_rs::Decimal;
@@ -214,11 +213,9 @@ impl<'a> Value<'a> {
     }
 
     /// Attempts to serialize the JSONB Value into a byte stream.
-    pub fn to_writer<W: Write>(&self, mut writer: W) -> Result<(), Error> {
-        let mut buf = Vec::new();
-        let mut encoder = Encoder::new(&mut buf);
+    pub fn to_vec(&self, buf: &mut Vec<u8>) -> Result<(), Error> {
+        let mut encoder = Encoder::new(buf);
         encoder.encode(self)?;
-        writer.write_all(&buf)?;
         Ok(())
     }
 }

src/common/jsonb/src/value.rs

@@ -24,7 +24,7 @@ fn test_parse_null() {
     assert_eq!(value.as_null(), Some(()));
 
     let mut buf: Vec<u8> = Vec::new();
-    value.to_writer(&mut buf).unwrap();
+    value.to_vec(&mut buf).unwrap();
     assert_eq!(buf, b"\x20\0\0\0\0\0\0\0");
 }
 
@@ -35,7 +35,7 @@ fn test_parse_boolean() {
     assert_eq!(value.as_bool(), Some(true));
 
     let mut buf: Vec<u8> = Vec::new();
-    value.to_writer(&mut buf).unwrap();
+    value.to_vec(&mut buf).unwrap();
     assert_eq!(buf, b"\x20\0\0\0\x40\0\0\0");
 
     let s = r#"false"#;
@@ -44,7 +44,7 @@ fn test_parse_boolean() {
     assert_eq!(value.as_bool(), Some(false));
 
     let mut buf: Vec<u8> = Vec::new();
-    value.to_writer(&mut buf).unwrap();
+    value.to_vec(&mut buf).unwrap();
     assert_eq!(buf, b"\x20\0\0\0\x30\0\0\0");
 }
 
@@ -56,7 +56,7 @@ fn test_parse_number_int64() {
     assert_eq!(value.as_i64(), Some(-1234));
 
     let mut buf: Vec<u8> = Vec::new();
-    value.to_writer(&mut buf).unwrap();
+    value.to_vec(&mut buf).unwrap();
     assert_eq!(buf, b"\x20\0\0\0\x20\0\0\x04\x03\0\xd2\x04");
 
     let s = r#"34567890"#;
@@ -65,7 +65,7 @@ fn test_parse_number_int64() {
     assert_eq!(value.as_i64(), Some(34567890));
 
     let mut buf: Vec<u8> = Vec::new();
-    value.to_writer(&mut buf).unwrap();
+    value.to_vec(&mut buf).unwrap();
     assert_eq!(buf, b"\x20\0\0\0\x20\0\0\x06\x02\0\xd2\x76\x0f\x02");
 }
 
@@ -77,7 +77,7 @@ fn test_parse_number_float64() {
     assert_eq!(value.as_f64(), Some(0.0123));
 
     let mut buf: Vec<u8> = Vec::new();
-    value.to_writer(&mut buf).unwrap();
+    value.to_vec(&mut buf).unwrap();
     assert_eq!(buf, b"\x20\0\0\0\x20\0\0\x03\x02\x04\x7b");
 
     let s = r#"12.34e5"#;
@@ -86,7 +86,7 @@ fn test_parse_number_float64() {
     assert_eq!(value.as_f64(), Some(1234000.0));
 
     let mut buf: Vec<u8> = Vec::new();
-    value.to_writer(&mut buf).unwrap();
+    value.to_vec(&mut buf).unwrap();
     assert_eq!(buf, b"\x20\0\0\0\x20\0\0\x04\0\x03\xd2\x04");
 }
 
@@ -98,7 +98,7 @@ fn test_parse_string() {
     assert_eq!(value.as_str(), Some(&Cow::from("asd")));
 
     let mut buf: Vec<u8> = Vec::new();
-    value.to_writer(&mut buf).unwrap();
+    value.to_vec(&mut buf).unwrap();
     assert_eq!(buf, b"\x20\0\0\0\x10\0\0\x03\x61\x73\x64");
 
     let s = r#""\\\"abc\\\"""#;
@@ -107,7 +107,7 @@ fn test_parse_string() {
     assert_eq!(value.as_str(), Some(&Cow::from("\\\"abc\\\"")));
 
     let mut buf: Vec<u8> = Vec::new();
-    value.to_writer(&mut buf).unwrap();
+    value.to_vec(&mut buf).unwrap();
     assert_eq!(buf, b"\x20\0\0\0\x10\0\0\x07\x5c\x22\x61\x62\x63\x5c\x22");
 
     let s = r#""测试abc""#;
@@ -116,7 +116,7 @@ fn test_parse_string() {
     assert_eq!(value.as_str(), Some(&Cow::from("测试abc")));
 
     let mut buf: Vec<u8> = Vec::new();
-    value.to_writer(&mut buf).unwrap();
+    value.to_vec(&mut buf).unwrap();
     assert_eq!(
         buf,
         b"\x20\0\0\0\x10\0\0\x09\xe6\xb5\x8b\xe8\xaf\x95\x61\x62\x63"
@@ -128,7 +128,7 @@ fn test_parse_string() {
     assert_eq!(value.as_str(), Some(&Cow::from("€")));
 
     let mut buf: Vec<u8> = Vec::new();
-    value.to_writer(&mut buf).unwrap();
+    value.to_vec(&mut buf).unwrap();
     assert_eq!(buf, b"\x20\0\0\0\x10\0\0\x03\xe2\x82\xac");
 }
 
@@ -139,15 +139,15 @@ fn test_parse_array() {
     assert!(value.is_array());
 
     let mut buf: Vec<u8> = Vec::new();
-    value.to_writer(&mut buf).unwrap();
+    value.to_vec(&mut buf).unwrap();
     assert_eq!(buf, b"\x80\0\0\x06\x40\0\0\0\x20\0\0\x02\x20\0\0\x03\x20\0\0\x05\x10\0\0\x03\x50\0\0\x04\x39\x30\x03\0\xc8\x02\x04\xc2\x12\x0c\x61\x73\x64\x80\0\0\0");
 
     let s = r#"[1,2,3,["a","b","c"]]"#;
     let value = parse_value(s.as_bytes()).unwrap();
     assert!(value.is_array());
 
     let mut buf: Vec<u8> = Vec::new();
-    value.to_writer(&mut buf).unwrap();
+    value.to_vec(&mut buf).unwrap();
     assert_eq!(buf, b"\x80\0\0\x04\x20\0\0\x01\x20\0\0\x01\x20\0\0\x01\x50\0\0\x13\x01\x02\x03\x80\0\0\x03\x10\0\0\x01\x10\0\0\x01\x10\0\0\x01\x61\x62\x63");
 }
 
@@ -158,15 +158,15 @@ fn test_parse_object() {
     assert!(value.is_object());
 
     let mut buf: Vec<u8> = Vec::new();
-    value.to_writer(&mut buf).unwrap();
+    value.to_vec(&mut buf).unwrap();
     assert_eq!(buf, b"\x40\0\0\x02\x10\0\0\x02\x10\0\0\x02\x10\0\0\x02\x10\0\0\x02\x6b\x31\x6b\x32\x76\x31\x76\x32");
 
     let s = r#"{"k":"v","a":"b"}"#;
     let value = parse_value(s.as_bytes()).unwrap();
     assert!(value.is_object());
 
     let mut buf: Vec<u8> = Vec::new();
-    value.to_writer(&mut buf).unwrap();
+    value.to_vec(&mut buf).unwrap();
     assert_eq!(
         buf,
         b"\x40\0\0\x02\x10\0\0\x01\x10\0\0\x01\x10\0\0\x01\x10\0\0\x01\x61\x6b\x62\x76"