Intermediate changes

commit_hash:22545c4aa243324b513d4c90832d07cc85d8a6cf

26 files changed, 416 insertions, 0 deletions

diff --git a/yql/essentials/tests/sql/minirun/part0/canondata/result.json b/yql/essentials/tests/sql/minirun/part0/canondata/result.json
index 209766edb69..cecc1d216b3 100644
--- a/yql/essentials/tests/sql/minirun/part0/canondata/result.json
+++ b/yql/essentials/tests/sql/minirun/part0/canondata/result.json
@@ -261,6 +261,27 @@
             "uri": "https://{canondata_backend}/1920236/e2416b57cd9baa140c086892d357d5945ed0fdb1/resource.tar.gz#test.test_blocks-and-default.txt-Results_/results.txt"
         }
     ],
+    "test.test[blocks-pg_call-default.txt-Debug]": [
+        {
+            "checksum": "34def2ef08f7d1306e6bfe6afe7bde8f",
+            "size": 701,
+            "uri": "https://{canondata_backend}/1814674/d1d41a17170e55fd1f93d85f4708eb5282bce7d2/resource.tar.gz#test.test_blocks-pg_call-default.txt-Debug_/opt.yql"
+        }
+    ],
+    "test.test[blocks-pg_call-default.txt-Peephole]": [
+        {
+            "checksum": "4b035ae018652e54247b56a686325bb4",
+            "size": 887,
+            "uri": "https://{canondata_backend}/1814674/d1d41a17170e55fd1f93d85f4708eb5282bce7d2/resource.tar.gz#test.test_blocks-pg_call-default.txt-Peephole_/opt.yql"
+        }
+    ],
+    "test.test[blocks-pg_call-default.txt-Results]": [
+        {
+            "checksum": "0c1271771d3ec413f22fdd8c115f2dd6",
+            "size": 1370,
+            "uri": "https://{canondata_backend}/1814674/d1d41a17170e55fd1f93d85f4708eb5282bce7d2/resource.tar.gz#test.test_blocks-pg_call-default.txt-Results_/results.txt"
+        }
+    ],
     "test.test[blocks-xor-default.txt-Debug]": [
         {
             "checksum": "f0b56bd3576e6d9f549d692dff6522c8",
diff --git a/yql/essentials/tests/sql/minirun/part3/canondata/result.json b/yql/essentials/tests/sql/minirun/part3/canondata/result.json
index 4db0b286873..518dcf729de 100644
--- a/yql/essentials/tests/sql/minirun/part3/canondata/result.json
+++ b/yql/essentials/tests/sql/minirun/part3/canondata/result.json
@@ -285,6 +285,27 @@
             "uri": "file://test.test_bitcast_implicit-div_bitcast-default.txt-Results_/extracted"
         }
     ],
+    "test.test[blocks-frompg-default.txt-Debug]": [
+        {
+            "checksum": "52d5daf2447e1de0d4cf3150468c9de5",
+            "size": 361,
+            "uri": "https://{canondata_backend}/1775319/25a92a1cd773ccebf59751427286ef1fe45aeeb2/resource.tar.gz#test.test_blocks-frompg-default.txt-Debug_/opt.yql"
+        }
+    ],
+    "test.test[blocks-frompg-default.txt-Peephole]": [
+        {
+            "checksum": "e245ccef92be3a037238558f8908427b",
+            "size": 531,
+            "uri": "https://{canondata_backend}/1775319/25a92a1cd773ccebf59751427286ef1fe45aeeb2/resource.tar.gz#test.test_blocks-frompg-default.txt-Peephole_/opt.yql"
+        }
+    ],
+    "test.test[blocks-frompg-default.txt-Results]": [
+        {
+            "checksum": "19876b1dd470207f15ec98224449a5a3",
+            "size": 958,
+            "uri": "https://{canondata_backend}/1775319/25a92a1cd773ccebf59751427286ef1fe45aeeb2/resource.tar.gz#test.test_blocks-frompg-default.txt-Results_/results.txt"
+        }
+    ],
     "test.test[blocks-or_opt-default.txt-Debug]": [
         {
             "checksum": "85fb6a988595cab34e899acfd0ef8dd2",
diff --git a/yql/essentials/tests/sql/minirun/part5/canondata/result.json b/yql/essentials/tests/sql/minirun/part5/canondata/result.json
index 406b42e25d6..0fc1d285afc 100644
--- a/yql/essentials/tests/sql/minirun/part5/canondata/result.json
+++ b/yql/essentials/tests/sql/minirun/part5/canondata/result.json
@@ -345,6 +345,27 @@
             "uri": "https://{canondata_backend}/1942671/ce51ce34754ddc48cce99d0eb0d68c58043ce298/resource.tar.gz#test.test_blocks-and_opt-default.txt-Results_/results.txt"
         }
     ],
+    "test.test[blocks-decimal_binop-default.txt-Debug]": [
+        {
+            "checksum": "36ae0e625c8e7bc9ff869827c5b36a33",
+            "size": 389,
+            "uri": "https://{canondata_backend}/1775319/488597481a390ab007602d4f2c7cb21f0d5833de/resource.tar.gz#test.test_blocks-decimal_binop-default.txt-Debug_/opt.yql"
+        }
+    ],
+    "test.test[blocks-decimal_binop-default.txt-Peephole]": [
+        {
+            "checksum": "e165bc99d0eeb90c4e09d377dfa0609b",
+            "size": 732,
+            "uri": "https://{canondata_backend}/1775319/488597481a390ab007602d4f2c7cb21f0d5833de/resource.tar.gz#test.test_blocks-decimal_binop-default.txt-Peephole_/opt.yql"
+        }
+    ],
+    "test.test[blocks-decimal_binop-default.txt-Results]": [
+        {
+            "checksum": "0a482cb584916b15cf01e8bfddbd92fb",
+            "size": 1535,
+            "uri": "https://{canondata_backend}/1775319/488597481a390ab007602d4f2c7cb21f0d5833de/resource.tar.gz#test.test_blocks-decimal_binop-default.txt-Results_/results.txt"
+        }
+    ],
     "test.test[blocks-filter-default.txt-Debug]": [
         {
             "checksum": "3dea830ec45f78ed78603576b054b4ca",
@@ -366,6 +387,27 @@
             "uri": "https://{canondata_backend}/1937150/d87c401e99a94fad9fdc66f7c4a0d9c670b84949/resource.tar.gz#test.test_blocks-filter-default.txt-Results_/results.txt"
         }
     ],
+    "test.test[blocks-just-default.txt-Debug]": [
+        {
+            "checksum": "248412653c63c6892f76b6ed3c91a2ae",
+            "size": 230,
+            "uri": "https://{canondata_backend}/1775319/488597481a390ab007602d4f2c7cb21f0d5833de/resource.tar.gz#test.test_blocks-just-default.txt-Debug_/opt.yql"
+        }
+    ],
+    "test.test[blocks-just-default.txt-Peephole]": [
+        {
+            "checksum": "d51f71d182470ef3d43b3082d7d48fb8",
+            "size": 468,
+            "uri": "https://{canondata_backend}/1775319/488597481a390ab007602d4f2c7cb21f0d5833de/resource.tar.gz#test.test_blocks-just-default.txt-Peephole_/opt.yql"
+        }
+    ],
+    "test.test[blocks-just-default.txt-Results]": [
+        {
+            "checksum": "f9a40ce704e450668912cbb5f4baeef9",
+            "size": 887,
+            "uri": "https://{canondata_backend}/1775319/488597481a390ab007602d4f2c7cb21f0d5833de/resource.tar.gz#test.test_blocks-just-default.txt-Results_/results.txt"
+        }
+    ],
     "test.test[blocks-not-default.txt-Debug]": [
         {
             "checksum": "11ca4c4fbc3e6a5463a95ce9496effdf",
diff --git a/yql/essentials/tests/sql/minirun/part6/canondata/result.json b/yql/essentials/tests/sql/minirun/part6/canondata/result.json
index 8c8ddbc9f51..088e4d2a314 100644
--- a/yql/essentials/tests/sql/minirun/part6/canondata/result.json
+++ b/yql/essentials/tests/sql/minirun/part6/canondata/result.json
@@ -317,6 +317,27 @@
             "uri": "https://{canondata_backend}/1920236/8a88b220fe1ff8b571b6813b812d7623629101fd/resource.tar.gz#test.test_blocks-coalesce_scalar-default.txt-Results_/results.txt"
         }
     ],
+    "test.test[blocks-member-default.txt-Debug]": [
+        {
+            "checksum": "b73a845c0abd3dddfca9888bbf83560a",
+            "size": 416,
+            "uri": "https://{canondata_backend}/1900335/81a360a61ba1555c418f20e4c99272eb22766040/resource.tar.gz#test.test_blocks-member-default.txt-Debug_/opt.yql"
+        }
+    ],
+    "test.test[blocks-member-default.txt-Peephole]": [
+        {
+            "checksum": "b40c6c197f750c6a604329621bd37300",
+            "size": 586,
+            "uri": "https://{canondata_backend}/1900335/81a360a61ba1555c418f20e4c99272eb22766040/resource.tar.gz#test.test_blocks-member-default.txt-Peephole_/opt.yql"
+        }
+    ],
+    "test.test[blocks-member-default.txt-Results]": [
+        {
+            "checksum": "8b1bee266dfa36a94d77f728d69f95ad",
+            "size": 961,
+            "uri": "https://{canondata_backend}/1900335/81a360a61ba1555c418f20e4c99272eb22766040/resource.tar.gz#test.test_blocks-member-default.txt-Results_/results.txt"
+        }
+    ],
     "test.test[blocks-projection_add_ints_filter-default.txt-Debug]": [
         {
             "checksum": "0dc7c149ab903b62717b7afe506ab893",
diff --git a/yql/essentials/tests/sql/minirun/part7/canondata/result.json b/yql/essentials/tests/sql/minirun/part7/canondata/result.json
index e4d2c99469a..3adddc5fb49 100644
--- a/yql/essentials/tests/sql/minirun/part7/canondata/result.json
+++ b/yql/essentials/tests/sql/minirun/part7/canondata/result.json
@@ -209,6 +209,27 @@
             "uri": "https://{canondata_backend}/1920236/d08588ad74710b9926df45a5b372c37153cb8b1e/resource.tar.gz#test.test_bigdate-misc-default.txt-Results_/results.txt"
         }
     ],
+    "test.test[blocks-as_tuple-default.txt-Debug]": [
+        {
+            "checksum": "0e965c2d9b0db25f4d2fab145332abbb",
+            "size": 288,
+            "uri": "https://{canondata_backend}/1775319/ebad1e34262c6a71e8c6dbf23efe7ba30e371e75/resource.tar.gz#test.test_blocks-as_tuple-default.txt-Debug_/opt.yql"
+        }
+    ],
+    "test.test[blocks-as_tuple-default.txt-Peephole]": [
+        {
+            "checksum": "dc0005ecb6750c691d66fe6c50e00d0c",
+            "size": 603,
+            "uri": "https://{canondata_backend}/1775319/ebad1e34262c6a71e8c6dbf23efe7ba30e371e75/resource.tar.gz#test.test_blocks-as_tuple-default.txt-Peephole_/opt.yql"
+        }
+    ],
+    "test.test[blocks-as_tuple-default.txt-Results]": [
+        {
+            "checksum": "41c77ef11f22f1696fcda9bb0c1a4515",
+            "size": 2005,
+            "uri": "https://{canondata_backend}/1775319/ebad1e34262c6a71e8c6dbf23efe7ba30e371e75/resource.tar.gz#test.test_blocks-as_tuple-default.txt-Results_/results.txt"
+        }
+    ],
     "test.test[blocks-or-default.txt-Debug]": [
         {
             "checksum": "4c3c28b4c505737765e9379d3386b4ff",
@@ -230,6 +251,27 @@
             "uri": "https://{canondata_backend}/1942671/a9486852a02ad9ecba5005ac92cde1261882e326/resource.tar.gz#test.test_blocks-or-default.txt-Results_/results.txt"
         }
     ],
+    "test.test[blocks-topg-default.txt-Debug]": [
+        {
+            "checksum": "689f15316094944d5027603befe3f31a",
+            "size": 367,
+            "uri": "https://{canondata_backend}/1775319/ebad1e34262c6a71e8c6dbf23efe7ba30e371e75/resource.tar.gz#test.test_blocks-topg-default.txt-Debug_/opt.yql"
+        }
+    ],
+    "test.test[blocks-topg-default.txt-Peephole]": [
+        {
+            "checksum": "adfdcd16ed6e227522ee922fd1e818c8",
+            "size": 537,
+            "uri": "https://{canondata_backend}/1775319/ebad1e34262c6a71e8c6dbf23efe7ba30e371e75/resource.tar.gz#test.test_blocks-topg-default.txt-Peephole_/opt.yql"
+        }
+    ],
+    "test.test[blocks-topg-default.txt-Results]": [
+        {
+            "checksum": "200c7ace6be24a899424965b6aba5fb3",
+            "size": 804,
+            "uri": "https://{canondata_backend}/1775319/ebad1e34262c6a71e8c6dbf23efe7ba30e371e75/resource.tar.gz#test.test_blocks-topg-default.txt-Results_/results.txt"
+        }
+    ],
     "test.test[case-case_opt_then-default.txt-Debug]": [
         {
             "checksum": "456497d68c16bc496296525c7d2fadd5",
diff --git a/yql/essentials/tests/sql/minirun/part8/canondata/result.json b/yql/essentials/tests/sql/minirun/part8/canondata/result.json
index a041fe1469d..de9da9c5b2d 100644
--- a/yql/essentials/tests/sql/minirun/part8/canondata/result.json
+++ b/yql/essentials/tests/sql/minirun/part8/canondata/result.json
@@ -394,6 +394,27 @@
             "uri": "https://{canondata_backend}/1942671/1fe07dc7779a4d1b05048ad4f78bfbeb3a86d998/resource.tar.gz#test.test_blocks-if-default.txt-Results_/results.txt"
         }
     ],
+    "test.test[blocks-pg_op-default.txt-Debug]": [
+        {
+            "checksum": "726a0ff9b5ab151301d52192bfc274d2",
+            "size": 677,
+            "uri": "https://{canondata_backend}/1900335/9f3e189e481af8d65c06be72d7112a9ca1209c31/resource.tar.gz#test.test_blocks-pg_op-default.txt-Debug_/opt.yql"
+        }
+    ],
+    "test.test[blocks-pg_op-default.txt-Peephole]": [
+        {
+            "checksum": "7b89533ec36887d33beaa65ae0662d3f",
+            "size": 863,
+            "uri": "https://{canondata_backend}/1900335/9f3e189e481af8d65c06be72d7112a9ca1209c31/resource.tar.gz#test.test_blocks-pg_op-default.txt-Peephole_/opt.yql"
+        }
+    ],
+    "test.test[blocks-pg_op-default.txt-Results]": [
+        {
+            "checksum": "88cf292f03f7446cbd4a93928a3e0e38",
+            "size": 1398,
+            "uri": "https://{canondata_backend}/1900335/9f3e189e481af8d65c06be72d7112a9ca1209c31/resource.tar.gz#test.test_blocks-pg_op-default.txt-Results_/results.txt"
+        }
+    ],
     "test.test[blocks-xor_opt-default.txt-Debug]": [
         {
             "checksum": "91e8a0bee949446ecd2a7ed7703756fe",
diff --git a/yql/essentials/tests/sql/minirun/part9/canondata/result.json b/yql/essentials/tests/sql/minirun/part9/canondata/result.json
index 84ff18d5853..4d4e7caa3bf 100644
--- a/yql/essentials/tests/sql/minirun/part9/canondata/result.json
+++ b/yql/essentials/tests/sql/minirun/part9/canondata/result.json
@@ -209,6 +209,27 @@
             "uri": "https://{canondata_backend}/1920236/19a9934ebc9455bf1caab37058331acdf3c4ee26/resource.tar.gz#test.test_blocks-if_scalar-default.txt-Results_/results.txt"
         }
     ],
+    "test.test[blocks-nth-default.txt-Debug]": [
+        {
+            "checksum": "33ec59138b81baf86a6a09b1a69cb923",
+            "size": 421,
+            "uri": "https://{canondata_backend}/1900335/892d26e90090b841f50bacde742fd87e2ef88a38/resource.tar.gz#test.test_blocks-nth-default.txt-Debug_/opt.yql"
+        }
+    ],
+    "test.test[blocks-nth-default.txt-Peephole]": [
+        {
+            "checksum": "e06d2c11c8bad42802c715436faa44c0",
+            "size": 591,
+            "uri": "https://{canondata_backend}/1900335/892d26e90090b841f50bacde742fd87e2ef88a38/resource.tar.gz#test.test_blocks-nth-default.txt-Peephole_/opt.yql"
+        }
+    ],
+    "test.test[blocks-nth-default.txt-Results]": [
+        {
+            "checksum": "8b1bee266dfa36a94d77f728d69f95ad",
+            "size": 961,
+            "uri": "https://{canondata_backend}/1900335/892d26e90090b841f50bacde742fd87e2ef88a38/resource.tar.gz#test.test_blocks-nth-default.txt-Results_/results.txt"
+        }
+    ],
     "test.test[blocks-projection_add_ints-default.txt-Debug]": [
         {
             "checksum": "0dc7c149ab903b62717b7afe506ab893",
diff --git a/yql/essentials/tests/sql/sql2yql/canondata/result.json b/yql/essentials/tests/sql/sql2yql/canondata/result.json
index 4d5c62cb0bc..9fec09ba5f0 100644
--- a/yql/essentials/tests/sql/sql2yql/canondata/result.json
+++ b/yql/essentials/tests/sql/sql2yql/canondata/result.json
@@ -1343,6 +1343,13 @@
             "uri": "https://{canondata_backend}/1916746/15a617669fb2b654b6be1fc493d61b99fb1f6f81/resource.tar.gz#test_sql2yql.test_blocks-and_scalar_/sql.yql"
         }
     ],
+    "test_sql2yql.test[blocks-as_tuple]": [
+        {
+            "checksum": "601f02d489707b615a9ff16a4fe1d3f5",
+            "size": 1304,
+            "uri": "https://{canondata_backend}/1900335/c447765ddbde200b8fe3ee8091f4d625b36b6bc6/resource.tar.gz#test_sql2yql.test_blocks-as_tuple_/sql.yql"
+        }
+    ],
     "test_sql2yql.test[blocks-coalesce]": [
         {
             "checksum": "d407fef7972254e7c63c8b55750b8d4a",
@@ -1357,6 +1364,13 @@
             "uri": "https://{canondata_backend}/1916746/15a617669fb2b654b6be1fc493d61b99fb1f6f81/resource.tar.gz#test_sql2yql.test_blocks-coalesce_scalar_/sql.yql"
         }
     ],
+    "test_sql2yql.test[blocks-decimal_binop]": [
+        {
+            "checksum": "ba0d166a10075020edf9630c95f688e0",
+            "size": 1541,
+            "uri": "https://{canondata_backend}/1900335/c447765ddbde200b8fe3ee8091f4d625b36b6bc6/resource.tar.gz#test_sql2yql.test_blocks-decimal_binop_/sql.yql"
+        }
+    ],
     "test_sql2yql.test[blocks-empty_as_table]": [
         {
             "checksum": "bbda02d622e3f3c4f698ea1962d9f902",
@@ -1378,6 +1392,13 @@
             "uri": "https://{canondata_backend}/1130705/7bfa4c7bef8ecf6ffba8b79d210708dc39bab04e/resource.tar.gz#test_sql2yql.test_blocks-filter_/sql.yql"
         }
     ],
+    "test_sql2yql.test[blocks-frompg]": [
+        {
+            "checksum": "0049311ab78f33b07832a7abf8792156",
+            "size": 1126,
+            "uri": "https://{canondata_backend}/1900335/c447765ddbde200b8fe3ee8091f4d625b36b6bc6/resource.tar.gz#test_sql2yql.test_blocks-frompg_/sql.yql"
+        }
+    ],
     "test_sql2yql.test[blocks-if]": [
         {
             "checksum": "2b573fa3534410c28b1273b496c93231",
@@ -1392,6 +1413,20 @@
             "uri": "https://{canondata_backend}/1916746/15a617669fb2b654b6be1fc493d61b99fb1f6f81/resource.tar.gz#test_sql2yql.test_blocks-if_scalar_/sql.yql"
         }
     ],
+    "test_sql2yql.test[blocks-just]": [
+        {
+            "checksum": "6e4505f61db05c3ede047edf22c68997",
+            "size": 1081,
+            "uri": "https://{canondata_backend}/1900335/c447765ddbde200b8fe3ee8091f4d625b36b6bc6/resource.tar.gz#test_sql2yql.test_blocks-just_/sql.yql"
+        }
+    ],
+    "test_sql2yql.test[blocks-member]": [
+        {
+            "checksum": "cf5cf545239509b0ec384396da6b77c0",
+            "size": 1197,
+            "uri": "https://{canondata_backend}/1900335/c447765ddbde200b8fe3ee8091f4d625b36b6bc6/resource.tar.gz#test_sql2yql.test_blocks-member_/sql.yql"
+        }
+    ],
     "test_sql2yql.test[blocks-not]": [
         {
             "checksum": "60ffa8348b787bc96b78945aa79545d2",
@@ -1406,6 +1441,13 @@
             "uri": "https://{canondata_backend}/1916746/15a617669fb2b654b6be1fc493d61b99fb1f6f81/resource.tar.gz#test_sql2yql.test_blocks-not_opt_/sql.yql"
         }
     ],
+    "test_sql2yql.test[blocks-nth]": [
+        {
+            "checksum": "4bce64c6fd9a1faed86401b27bc05ecb",
+            "size": 1175,
+            "uri": "https://{canondata_backend}/1900335/c447765ddbde200b8fe3ee8091f4d625b36b6bc6/resource.tar.gz#test_sql2yql.test_blocks-nth_/sql.yql"
+        }
+    ],
     "test_sql2yql.test[blocks-or]": [
         {
             "checksum": "1e7e91aab2807a411a6a8b24ff2db384",
@@ -1434,6 +1476,20 @@
             "uri": "https://{canondata_backend}/1916746/15a617669fb2b654b6be1fc493d61b99fb1f6f81/resource.tar.gz#test_sql2yql.test_blocks-or_scalar_/sql.yql"
         }
     ],
+    "test_sql2yql.test[blocks-pg_call]": [
+        {
+            "checksum": "32062809d5a13c1cbf4288a824da4a7f",
+            "size": 1680,
+            "uri": "https://{canondata_backend}/1900335/c447765ddbde200b8fe3ee8091f4d625b36b6bc6/resource.tar.gz#test_sql2yql.test_blocks-pg_call_/sql.yql"
+        }
+    ],
+    "test_sql2yql.test[blocks-pg_op]": [
+        {
+            "checksum": "6fde398b5c3fed0e3fa982b753fe6018",
+            "size": 1658,
+            "uri": "https://{canondata_backend}/1900335/c447765ddbde200b8fe3ee8091f4d625b36b6bc6/resource.tar.gz#test_sql2yql.test_blocks-pg_op_/sql.yql"
+        }
+    ],
     "test_sql2yql.test[blocks-projection_add_ints]": [
         {
             "checksum": "f84fc85138d4f1d4b72cf4d37a2b8ff2",
@@ -1448,6 +1504,13 @@
             "uri": "https://{canondata_backend}/1130705/7bfa4c7bef8ecf6ffba8b79d210708dc39bab04e/resource.tar.gz#test_sql2yql.test_blocks-projection_add_ints_filter_/sql.yql"
         }
     ],
+    "test_sql2yql.test[blocks-topg]": [
+        {
+            "checksum": "0f669eec4c7c11d663db474f09902bd4",
+            "size": 1107,
+            "uri": "https://{canondata_backend}/1900335/c447765ddbde200b8fe3ee8091f4d625b36b6bc6/resource.tar.gz#test_sql2yql.test_blocks-topg_/sql.yql"
+        }
+    ],
     "test_sql2yql.test[blocks-xor]": [
         {
             "checksum": "879bea5e15aa53dc4f3444f0fa17de49",
@@ -8029,6 +8092,11 @@
             "uri": "file://test_sql_format.test_blocks-and_scalar_/formatted.sql"
         }
     ],
+    "test_sql_format.test[blocks-as_tuple]": [
+        {
+            "uri": "file://test_sql_format.test_blocks-as_tuple_/formatted.sql"
+        }
+    ],
     "test_sql_format.test[blocks-coalesce]": [
         {
             "uri": "file://test_sql_format.test_blocks-coalesce_/formatted.sql"
@@ -8039,6 +8107,11 @@
             "uri": "file://test_sql_format.test_blocks-coalesce_scalar_/formatted.sql"
         }
     ],
+    "test_sql_format.test[blocks-decimal_binop]": [
+        {
+            "uri": "file://test_sql_format.test_blocks-decimal_binop_/formatted.sql"
+        }
+    ],
     "test_sql_format.test[blocks-empty_as_table]": [
         {
             "uri": "file://test_sql_format.test_blocks-empty_as_table_/formatted.sql"
@@ -8054,6 +8127,11 @@
             "uri": "file://test_sql_format.test_blocks-filter_/formatted.sql"
         }
     ],
+    "test_sql_format.test[blocks-frompg]": [
+        {
+            "uri": "file://test_sql_format.test_blocks-frompg_/formatted.sql"
+        }
+    ],
     "test_sql_format.test[blocks-if]": [
         {
             "uri": "file://test_sql_format.test_blocks-if_/formatted.sql"
@@ -8064,6 +8142,16 @@
             "uri": "file://test_sql_format.test_blocks-if_scalar_/formatted.sql"
         }
     ],
+    "test_sql_format.test[blocks-just]": [
+        {
+            "uri": "file://test_sql_format.test_blocks-just_/formatted.sql"
+        }
+    ],
+    "test_sql_format.test[blocks-member]": [
+        {
+            "uri": "file://test_sql_format.test_blocks-member_/formatted.sql"
+        }
+    ],
     "test_sql_format.test[blocks-not]": [
         {
             "uri": "file://test_sql_format.test_blocks-not_/formatted.sql"
@@ -8074,6 +8162,11 @@
             "uri": "file://test_sql_format.test_blocks-not_opt_/formatted.sql"
         }
     ],
+    "test_sql_format.test[blocks-nth]": [
+        {
+            "uri": "file://test_sql_format.test_blocks-nth_/formatted.sql"
+        }
+    ],
     "test_sql_format.test[blocks-or]": [
         {
             "uri": "file://test_sql_format.test_blocks-or_/formatted.sql"
@@ -8094,6 +8187,16 @@
             "uri": "file://test_sql_format.test_blocks-or_scalar_/formatted.sql"
         }
     ],
+    "test_sql_format.test[blocks-pg_call]": [
+        {
+            "uri": "file://test_sql_format.test_blocks-pg_call_/formatted.sql"
+        }
+    ],
+    "test_sql_format.test[blocks-pg_op]": [
+        {
+            "uri": "file://test_sql_format.test_blocks-pg_op_/formatted.sql"
+        }
+    ],
     "test_sql_format.test[blocks-projection_add_ints]": [
         {
             "uri": "file://test_sql_format.test_blocks-projection_add_ints_/formatted.sql"
@@ -8104,6 +8207,11 @@
             "uri": "file://test_sql_format.test_blocks-projection_add_ints_filter_/formatted.sql"
         }
     ],
+    "test_sql_format.test[blocks-topg]": [
+        {
+            "uri": "file://test_sql_format.test_blocks-topg_/formatted.sql"
+        }
+    ],
     "test_sql_format.test[blocks-xor]": [
         {
             "uri": "file://test_sql_format.test_blocks-xor_/formatted.sql"
diff --git a/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-as_tuple_/formatted.sql b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-as_tuple_/formatted.sql
new file mode 100644
index 00000000000..9ece992b4fd
--- /dev/null
+++ b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-as_tuple_/formatted.sql
@@ -0,0 +1,8 @@
+$data = [<|x: 1, y: 'foo'|>];
+
+SELECT
+    (x, 1),
+    (x, y)
+FROM
+    as_table($data)
+;
diff --git a/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-decimal_binop_/formatted.sql b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-decimal_binop_/formatted.sql
new file mode 100644
index 00000000000..6cb72a57b80
--- /dev/null
+++ b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-decimal_binop_/formatted.sql
@@ -0,0 +1,11 @@
+$data = [
+    <|x: Decimal('3', 5, 1), y: Decimal('2', 5, 1)|>,
+];
+
+SELECT
+    x * y,
+    x / y,
+    x % y
+FROM
+    as_table($data)
+;
diff --git a/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-frompg_/formatted.sql b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-frompg_/formatted.sql
new file mode 100644
index 00000000000..41d7bad3b4a
--- /dev/null
+++ b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-frompg_/formatted.sql
@@ -0,0 +1,7 @@
+$data = [<|x: 1p|>, <|x: NULL|>];
+
+SELECT
+    FromPg(x)
+FROM
+    as_table($data)
+;
diff --git a/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-just_/formatted.sql b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-just_/formatted.sql
new file mode 100644
index 00000000000..223604cae23
--- /dev/null
+++ b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-just_/formatted.sql
@@ -0,0 +1,7 @@
+$data = [<|x: 1|>];
+
+SELECT
+    just(x)
+FROM
+    as_table($data)
+;
diff --git a/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-member_/formatted.sql b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-member_/formatted.sql
new file mode 100644
index 00000000000..ff82e55e506
--- /dev/null
+++ b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-member_/formatted.sql
@@ -0,0 +1,7 @@
+$data = [<|x: <|a: 'foo'|>|>, <|x: <|a: NULL|>|>];
+
+SELECT
+    x.a
+FROM
+    as_table($data)
+;
diff --git a/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-nth_/formatted.sql b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-nth_/formatted.sql
new file mode 100644
index 00000000000..33104f38cd4
--- /dev/null
+++ b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-nth_/formatted.sql
@@ -0,0 +1,7 @@
+$data = [<|x: (1, 'foo')|>, <|x: NULL|>];
+
+SELECT
+    x.1
+FROM
+    as_table($data)
+;
diff --git a/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-pg_call_/formatted.sql b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-pg_call_/formatted.sql
new file mode 100644
index 00000000000..4cb1104020b
--- /dev/null
+++ b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-pg_call_/formatted.sql
@@ -0,0 +1,13 @@
+$data = [
+    <|x: 0p, y: 0p|>,
+    <|x: 0p, y: 1p|>,
+    <|x: 1p, y: 0p|>,
+    <|x: 1p, y: 1p|>,
+];
+
+SELECT
+    PgCall('int4pl', x, y),
+    PgCall('int4pl', x, 1p)
+FROM
+    as_table($data)
+;
diff --git a/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-pg_op_/formatted.sql b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-pg_op_/formatted.sql
new file mode 100644
index 00000000000..6bca912f57e
--- /dev/null
+++ b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-pg_op_/formatted.sql
@@ -0,0 +1,13 @@
+$data = [
+    <|x: 0p, y: 0p|>,
+    <|x: 0p, y: 1p|>,
+    <|x: 1p, y: 0p|>,
+    <|x: 1p, y: 1p|>,
+];
+
+SELECT
+    PgOp('=', x, y),
+    PgOp('=', x, 1p)
+FROM
+    as_table($data)
+;
diff --git a/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-topg_/formatted.sql b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-topg_/formatted.sql
new file mode 100644
index 00000000000..d8819bc415f
--- /dev/null
+++ b/yql/essentials/tests/sql/sql2yql/canondata/test_sql_format.test_blocks-topg_/formatted.sql
@@ -0,0 +1,7 @@
+$data = [<|x: 1|>, <|x: NULL|>];
+
+SELECT
+    ToPg(x)
+FROM
+    as_table($data)
+;
diff --git a/yql/essentials/tests/sql/suites/blocks/as_tuple.sql b/yql/essentials/tests/sql/suites/blocks/as_tuple.sql
new file mode 100644
index 00000000000..d585acd643e
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/blocks/as_tuple.sql
@@ -0,0 +1,3 @@
+$data = [<|x:1,y:'foo'|>];
+
+select (x,1),(x,y) from as_table($data);
diff --git a/yql/essentials/tests/sql/suites/blocks/decimal_binop.sql b/yql/essentials/tests/sql/suites/blocks/decimal_binop.sql
new file mode 100644
index 00000000000..3a4d1e587c5
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/blocks/decimal_binop.sql
@@ -0,0 +1,5 @@
+$data = [
+    <|x:Decimal('3',5,1),y:Decimal('2',5,1)|>,
+];
+
+select x * y, x / y, x % y from as_table($data);
diff --git a/yql/essentials/tests/sql/suites/blocks/frompg.sql b/yql/essentials/tests/sql/suites/blocks/frompg.sql
new file mode 100644
index 00000000000..24073f8214a
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/blocks/frompg.sql
@@ -0,0 +1,3 @@
+$data = [<|x:1p|>,<|x:null|>];
+
+select FromPg(x) from as_table($data);
diff --git a/yql/essentials/tests/sql/suites/blocks/just.sql b/yql/essentials/tests/sql/suites/blocks/just.sql
new file mode 100644
index 00000000000..6ebc57f7d8d
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/blocks/just.sql
@@ -0,0 +1,3 @@
+$data = [<|x:1|>];
+
+select just(x) from as_table($data);
diff --git a/yql/essentials/tests/sql/suites/blocks/member.sql b/yql/essentials/tests/sql/suites/blocks/member.sql
new file mode 100644
index 00000000000..d9599c97766
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/blocks/member.sql
@@ -0,0 +1,3 @@
+$data = [<|x:<|a:'foo'|>|>,<|x:<|a:null|>|>];
+
+select x.a from as_table($data);
diff --git a/yql/essentials/tests/sql/suites/blocks/nth.sql b/yql/essentials/tests/sql/suites/blocks/nth.sql
new file mode 100644
index 00000000000..46e73547501
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/blocks/nth.sql
@@ -0,0 +1,3 @@
+$data = [<|x:(1,'foo')|>,<|x:null|>];
+
+select x.1 from as_table($data);
diff --git a/yql/essentials/tests/sql/suites/blocks/pg_call.sql b/yql/essentials/tests/sql/suites/blocks/pg_call.sql
new file mode 100644
index 00000000000..1964e6cd7c6
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/blocks/pg_call.sql
@@ -0,0 +1,8 @@
+$data = [
+    <|x:0p,y:0p|>,
+    <|x:0p,y:1p|>,
+    <|x:1p,y:0p|>,
+    <|x:1p,y:1p|>,
+];
+
+select PgCall("int4pl",x,y),PgCall("int4pl",x,1p) from as_table($data);
diff --git a/yql/essentials/tests/sql/suites/blocks/pg_op.sql b/yql/essentials/tests/sql/suites/blocks/pg_op.sql
new file mode 100644
index 00000000000..a7a78513029
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/blocks/pg_op.sql
@@ -0,0 +1,8 @@
+$data = [
+    <|x:0p,y:0p|>,
+    <|x:0p,y:1p|>,
+    <|x:1p,y:0p|>,
+    <|x:1p,y:1p|>,
+];
+
+select PgOp("=",x,y),PgOp("=",x,1p) from as_table($data);
diff --git a/yql/essentials/tests/sql/suites/blocks/topg.sql b/yql/essentials/tests/sql/suites/blocks/topg.sql
new file mode 100644
index 00000000000..29079906043
--- /dev/null
+++ b/yql/essentials/tests/sql/suites/blocks/topg.sql
@@ -0,0 +1,3 @@
+$data = [<|x:1|>,<|x:null|>];
+
+select ToPg(x) from as_table($data);