[Feature] update assert sink check

apache · Sep 18, 2023 · 1af0b31 · 1af0b31
1 parent 01865f2
commit 1af0b31
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 29 deletions.
diff --git a/.../seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/e2e_lzo.json b/.../seatunnel-connector-v2-e2e/connector-file-local-e2e/src/test/resources/json/e2e_lzo.json
diff --git a/...-e2e/connector-file-local-e2e/src/test/resources/json/local_file_json_lzo_to_console.conf b/...-e2e/connector-file-local-e2e/src/test/resources/json/local_file_json_lzo_to_console.conf
@@ -27,6 +27,7 @@ env {
 
 source {
   LocalFile {
+    result_table_name = "fake"
     path = "/seatunnel/read/lzo_json"
     row_delimiter = "\n"
     partition_dir_expression = "${k0}=${v0}"
@@ -53,20 +54,20 @@ source {
         c_decimal = "decimal(38, 18)"
         c_timestamp = timestamp
         c_row = {
-          c_map = "map<string, string>"
-          c_array = "array<int>"
-          c_string = string
-          c_boolean = boolean
-          c_tinyint = tinyint
-          c_smallint = smallint
-          c_int = int
-          c_bigint = bigint
-          c_float = float
-          c_double = double
-          c_bytes = bytes
-          c_date = date
-          c_decimal = "decimal(38, 18)"
-          c_timestamp = timestamp
+          C_MAP = "map<string, string>"
+          C_ARRAY = "array<int>"
+          C_STRING = string
+          C_BOOLEAN = boolean
+          C_TINYINT = tinyint
+          C_SMALLINT = smallint
+          C_INT = int
+          C_BIGINT = bigint
+          C_FLOAT = float
+          C_DOUBLE = double
+          C_BYTES = bytes
+          C_DATE = date
+          C_DECIMAL = "decimal(38, 18)"
+          C_TIMESTAMP = timestamp
         }
       }
     }
@@ -76,9 +77,10 @@ source {
 
 sink {
   Console {
-
+    source_table_name = "fake"
   }
   Assert {
+    source_table_name = "fake"
     rules {
       row_rules = [
         {
@@ -92,7 +94,7 @@ sink {
           field_type = string
           field_value = [
             {
-              rule_type = NOT_NULL
+              equals_to = "WArEB"
             }
           ]
         },
@@ -110,25 +112,16 @@ sink {
           field_type = double
           field_value = [
             {
-              rule_type = NOT_NULL
+              equals_to = 12.4
             }
           ]
         },
         {
-          field_name = name
-          field_type = string
+          field_name = c_date
+          field_type = date
           field_value = [
             {
-              rule_type = NOT_NULL
-            }
-          ]
-        },
-        {
-          field_name = hobby
-          field_type = string
-          field_value = [
-            {
-              rule_type = NOT_NULL
+              equals_to = "2022-05-05"
             }
           ]
         }