Skip to content

Commit 18790fe

Browse files
mxkovalevmxkovalev
authored
Fix ToFlow optimizator with multiple usage (#6972)
1 parent 7cf9db7 commit 18790fe

File tree

13 files changed

+152
-162
lines changed

13 files changed

+152
-162
lines changed

‎ydb/library/yql/core/common_opt/yql_co_flow1.cpp

Lines changed: 0 additions & 87 deletions
Original file line numberDiff line numberDiff line change
@@ -1298,91 +1298,6 @@ TExprNode::TPtr OptimizeLookup(const TExprNode::TPtr& node, TExprContext& ctx, T
12981298
return node;
12991299
}
13001300

1301-
constexpr std::initializer_list<std::string_view> FlowPriority = {
1302-
"AssumeSorted", "AssumeUnique", "AssumeDistinct",
1303-
"Map", "OrderedMap", "MapNext",
1304-
"Filter", "OrderedFilter",
1305-
"FlatMap", "OrderedFlatMap",
1306-
"MultiMap", "OrderedMultiMap",
1307-
"FoldMap", "Fold1Map", "Chain1Map",
1308-
"Take", "Skip",
1309-
"TakeWhile", "SkipWhile",
1310-
"TakeWhileInclusive", "SkipWhileInclusive",
1311-
"SkipNullMembers", "FilterNullMembers",
1312-
"SkipNullElements", "FilterNullElements",
1313-
"Condense", "Condense1",
1314-
"MapJoinCore", "CommonJoinCore",
1315-
"CombineCore", "ExtractMembers",
1316-
"PartitionByKey", "SqueezeToDict"
1317-
};
1318-
1319-
TExprNode::TPtr OptimizeToFlow(const TExprNode::TPtr& node, TExprContext& ctx, TOptimizeContext& optCtx) {
1320-
if (!optCtx.IsSingleUsage(node->Head())) {
1321-
return node;
1322-
}
1323-
1324-
if (node->Head().IsCallable(FlowPriority)) {
1325-
YQL_CLOG(DEBUG, Core) << "Swap " << node->Content() << " with " << node->Head().Content();
1326-
return ctx.SwapWithHead(*node);
1327-
}
1328-
1329-
if (node->Head().IsCallable("FromFlow")) {
1330-
YQL_CLOG(DEBUG, Core) << "Drop " << node->Content() << " with " << node->Head().Content();
1331-
return node->Head().HeadPtr();
1332-
}
1333-
1334-
if (node->Head().IsCallable("ForwardList")) {
1335-
YQL_CLOG(DEBUG, Core) << "Drop " << node->Head().Content() << " under " << node->Content();
1336-
return ctx.ChangeChild(*node, 0U, node->Head().HeadPtr());
1337-
}
1338-
1339-
if (node->Head().IsCallable("Chopper")) {
1340-
YQL_CLOG(DEBUG, Core) << "Swap " << node->Head().Content() << " with " << node->Content();
1341-
auto children = node->Head().ChildrenList();
1342-
children.front() = ctx.ChangeChildren(*node, {std::move(children.front())});
1343-
children.back() = ctx.Builder(children.back()->Pos())
1344-
.Lambda()
1345-
.Param("key")
1346-
.Param("flow")
1347-
.Callable("ToFlow")
1348-
.Apply(0, *children.back())
1349-
.With(0, "key")
1350-
.With(1)
1351-
.Callable("FromFlow")
1352-
.Arg(0, "flow")
1353-
.Seal()
1354-
.Done()
1355-
.Seal()
1356-
.Seal()
1357-
.Seal().Build();
1358-
return ctx.ChangeChildren(node->Head(), std::move(children));
1359-
}
1360-
1361-
if (node->Head().IsCallable("Switch")) {
1362-
YQL_CLOG(DEBUG, Core) << "Swap " << node->Head().Content() << " with " << node->Content();
1363-
auto children = node->Head().ChildrenList();
1364-
children.front() = ctx.ChangeChildren(*node, {std::move(children.front())});
1365-
for (auto i = 3U; i < children.size(); ++++i) {
1366-
children[i] = ctx.Builder(children[i]->Pos())
1367-
.Lambda()
1368-
.Param("flow")
1369-
.Callable("ToFlow")
1370-
.Apply(0, *children[i])
1371-
.With(0)
1372-
.Callable("FromFlow")
1373-
.Arg(0, "flow")
1374-
.Seal()
1375-
.Done()
1376-
.Seal()
1377-
.Seal()
1378-
.Seal().Build();
1379-
}
1380-
return ctx.ChangeChildren(node->Head(), std::move(children));
1381-
}
1382-
1383-
return node;
1384-
}
1385-
13861301
template <bool Ordered>
13871302
TExprNode::TPtr OptimizeFlatMap(const TExprNode::TPtr& node, TExprContext& ctx, TOptimizeContext& optCtx) {
13881303
const std::conditional_t<Ordered, TCoOrderedFlatMap, TCoFlatMap> self(node);
@@ -1498,8 +1413,6 @@ TExprNode::TPtr OptimizeFlatMap(const TExprNode::TPtr& node, TExprContext& ctx,
14981413
void RegisterCoFlowCallables1(TCallableOptimizerMap& map) {
14991414
using namespace std::placeholders;
15001415

1501-
map["ToFlow"] = std::bind(&OptimizeToFlow, _1, _2, _3);
1502-
15031416
map["FlatMap"] = std::bind(&OptimizeFlatMap<false>, _1, _2, _3);
15041417
map["OrderedFlatMap"] = std::bind(&OptimizeFlatMap<true>, _1, _2, _3);
15051418

‎ydb/library/yql/core/common_opt/yql_co_simple1.cpp

Lines changed: 77 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2271,6 +2271,24 @@ TExprNode::TPtr HasNullOverVariant(const TExprNode::TPtr& node, TExprContext& ct
22712271

22722272
}
22732273

2274+
constexpr std::initializer_list<std::string_view> FlowPriority = {
2275+
"AssumeSorted", "AssumeUnique", "AssumeDistinct",
2276+
"Map", "OrderedMap", "MapNext",
2277+
"Filter", "OrderedFilter",
2278+
"FlatMap", "OrderedFlatMap",
2279+
"MultiMap", "OrderedMultiMap",
2280+
"FoldMap", "Fold1Map", "Chain1Map",
2281+
"Take", "Skip",
2282+
"TakeWhile", "SkipWhile",
2283+
"TakeWhileInclusive", "SkipWhileInclusive",
2284+
"SkipNullMembers", "FilterNullMembers",
2285+
"SkipNullElements", "FilterNullElements",
2286+
"Condense", "Condense1",
2287+
"MapJoinCore", "CommonJoinCore",
2288+
"CombineCore", "ExtractMembers",
2289+
"PartitionByKey", "SqueezeToDict"
2290+
};
2291+
22742292
TExprNode::TPtr OptimizeToFlow(const TExprNode::TPtr& node, TExprContext& ctx) {
22752293
if (node->Head().IsCallable("Nothing")) {
22762294
YQL_CLOG(DEBUG, Core) << node->Content() << " over " << node->Head().Content();
@@ -2297,6 +2315,65 @@ TExprNode::TPtr OptimizeToFlow(const TExprNode::TPtr& node, TExprContext& ctx) {
22972315
return ctx.ChangeChildren(*node, node->Head().ChildrenList());
22982316
}
22992317

2318+
if (node->Head().IsCallable(FlowPriority)) {
2319+
YQL_CLOG(DEBUG, Core) << "Swap " << node->Content() << " with " << node->Head().Content();
2320+
return ctx.SwapWithHead(*node);
2321+
}
2322+
2323+
if (node->Head().IsCallable("FromFlow")) {
2324+
YQL_CLOG(DEBUG, Core) << "Drop " << node->Content() << " with " << node->Head().Content();
2325+
return node->Head().HeadPtr();
2326+
}
2327+
2328+
if (node->Head().IsCallable("ForwardList")) {
2329+
YQL_CLOG(DEBUG, Core) << "Drop " << node->Head().Content() << " under " << node->Content();
2330+
return ctx.ChangeChild(*node, 0U, node->Head().HeadPtr());
2331+
}
2332+
2333+
if (node->Head().IsCallable("Chopper")) {
2334+
YQL_CLOG(DEBUG, Core) << "Swap " << node->Head().Content() << " with " << node->Content();
2335+
auto children = node->Head().ChildrenList();
2336+
children.front() = ctx.ChangeChildren(*node, {std::move(children.front())});
2337+
children.back() = ctx.Builder(children.back()->Pos())
2338+
.Lambda()
2339+
.Param("key")
2340+
.Param("flow")
2341+
.Callable("ToFlow")
2342+
.Apply(0, *children.back())
2343+
.With(0, "key")
2344+
.With(1)
2345+
.Callable("FromFlow")
2346+
.Arg(0, "flow")
2347+
.Seal()
2348+
.Done()
2349+
.Seal()
2350+
.Seal()
2351+
.Seal().Build();
2352+
return ctx.ChangeChildren(node->Head(), std::move(children));
2353+
}
2354+
2355+
if (node->Head().IsCallable("Switch")) {
2356+
YQL_CLOG(DEBUG, Core) << "Swap " << node->Head().Content() << " with " << node->Content();
2357+
auto children = node->Head().ChildrenList();
2358+
children.front() = ctx.ChangeChildren(*node, {std::move(children.front())});
2359+
for (auto i = 3U; i < children.size(); ++++i) {
2360+
children[i] = ctx.Builder(children[i]->Pos())
2361+
.Lambda()
2362+
.Param("flow")
2363+
.Callable("ToFlow")
2364+
.Apply(0, *children[i])
2365+
.With(0)
2366+
.Callable("FromFlow")
2367+
.Arg(0, "flow")
2368+
.Seal()
2369+
.Done()
2370+
.Seal()
2371+
.Seal()
2372+
.Seal().Build();
2373+
}
2374+
return ctx.ChangeChildren(node->Head(), std::move(children));
2375+
}
2376+
23002377
return node;
23012378
}
23022379

‎ydb/library/yql/tests/s-expressions/yt_native_file/part0/canondata/result.json

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1496,9 +1496,9 @@
14961496
],
14971497
"test.test[EquiJoinMap-JoinMapOpt1Key2-Debug]": [
14981498
{
1499-
"checksum": "e697c3541a74a899e6c2bc1d205fab7e",
1500-
"size": 12260,
1501-
"uri": "https://{canondata_backend}/1936997/eddc12f46844dcc083aab92a4d7028395471bd1e/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt1Key2-Debug_/opt.yql"
1499+
"checksum": "1c6930d45679382ee4b199b3595abfa5",
1500+
"size": 12103,
1501+
"uri": "https://{canondata_backend}/1784826/280894b68d0f84365de02760bedba1323759c046/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt1Key2-Debug_/opt.yql"
15021502
},
15031503
{
15041504
"checksum": "d41d8cd98f00b204e9800998ecf8427e",
@@ -1603,9 +1603,9 @@
16031603
],
16041604
"test.test[EquiJoinMap-JoinMapOpt1Key2-Plan]": [
16051605
{
1606-
"checksum": "da186e7214b63700e7a3faae84dfd196",
1607-
"size": 33255,
1608-
"uri": "https://{canondata_backend}/1936997/eddc12f46844dcc083aab92a4d7028395471bd1e/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt1Key2-Plan_/plan.txt"
1606+
"checksum": "f11d89ba700d9c98735408ba83965cae",
1607+
"size": 32683,
1608+
"uri": "https://{canondata_backend}/1784826/280894b68d0f84365de02760bedba1323759c046/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt1Key2-Plan_/plan.txt"
16091609
}
16101610
],
16111611
"test.test[EquiJoinMap-JoinMapOpt1Key2-Results]": [

‎ydb/library/yql/tests/s-expressions/yt_native_file/part1/canondata/result.json

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1444,9 +1444,9 @@
14441444
],
14451445
"test.test[EquiJoinMap-JoinMapOpt2Key2-Debug]": [
14461446
{
1447-
"checksum": "abec116368ed31e5dfbb0138d63c2600",
1448-
"size": 11570,
1449-
"uri": "https://{canondata_backend}/1936997/3fb71bce2d9d914e6b4ccf17de5db7fd43bb076a/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt2Key2-Debug_/opt.yql"
1447+
"checksum": "afae353d31d065d6727addee75e2bc59",
1448+
"size": 11484,
1449+
"uri": "https://{canondata_backend}/937458/0f57afbef9a099d0cf1b5ea3bcb5ab98632998ce/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt2Key2-Debug_/opt.yql"
14501450
},
14511451
{
14521452
"checksum": "d41d8cd98f00b204e9800998ecf8427e",
@@ -1551,9 +1551,9 @@
15511551
],
15521552
"test.test[EquiJoinMap-JoinMapOpt2Key2-Plan]": [
15531553
{
1554-
"checksum": "2cf3f104a9e25a6cb06a52e034d11e7a",
1555-
"size": 32089,
1556-
"uri": "https://{canondata_backend}/1936997/3fb71bce2d9d914e6b4ccf17de5db7fd43bb076a/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt2Key2-Plan_/plan.txt"
1554+
"checksum": "d2289aaff2b1dcb15b42421a2a2f7078",
1555+
"size": 31803,
1556+
"uri": "https://{canondata_backend}/937458/0f57afbef9a099d0cf1b5ea3bcb5ab98632998ce/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt2Key2-Plan_/plan.txt"
15571557
}
15581558
],
15591559
"test.test[EquiJoinMap-JoinMapOpt2Key2-Results]": [

‎ydb/library/yql/tests/s-expressions/yt_native_file/part2/canondata/result.json

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -969,9 +969,9 @@
969969
],
970970
"test.test[EquiJoin-EquiJoinConvertMapI8U8-Debug]": [
971971
{
972-
"checksum": "d87c1a23542fc29a1977933752acc149",
973-
"size": 53157,
974-
"uri": "https://{canondata_backend}/1923547/a0cc9646b39377ed13e6bfcf3d7a99167b242f62/resource.tar.gz#test.test_EquiJoin-EquiJoinConvertMapI8U8-Debug_/opt.yql"
972+
"checksum": "0da4ac3e3cba548f3830955be75158e0",
973+
"size": 53154,
974+
"uri": "https://{canondata_backend}/1916746/b18a726d33b8d46cddb25e10e1350d7c6bd71311/resource.tar.gz#test.test_EquiJoin-EquiJoinConvertMapI8U8-Debug_/opt.yql"
975975
},
976976
{
977977
"checksum": "de438775b4de1b6e9e8e2a94418df106",
@@ -1856,9 +1856,9 @@
18561856
],
18571857
"test.test[EquiJoin-EquiJoinConvertMapI8U8-Plan]": [
18581858
{
1859-
"checksum": "6725f33a77d357132f00caec43edb6d6",
1860-
"size": 154783,
1861-
"uri": "https://{canondata_backend}/1924537/2317e67e431b5a3d1571c00417bd8e0fbe0d40be/resource.tar.gz#test.test_EquiJoin-EquiJoinConvertMapI8U8-Plan_/plan.txt"
1859+
"checksum": "1ad8ccbd613815cef42b307779cacf0a",
1860+
"size": 153067,
1861+
"uri": "https://{canondata_backend}/1814674/895c74707cb831a9b51e52c29c51842f99f1f427/resource.tar.gz#test.test_EquiJoin-EquiJoinConvertMapI8U8-Plan_/plan.txt"
18621862
}
18631863
],
18641864
"test.test[EquiJoin-EquiJoinConvertMapI8U8-Results]": [

‎ydb/library/yql/tests/s-expressions/yt_native_file/part3/canondata/result.json

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -2579,9 +2579,9 @@
25792579
],
25802580
"test.test[EquiJoinMap-JoinMap-Debug]": [
25812581
{
2582-
"checksum": "06ba73f0eb6818cb88916897bb70f450",
2583-
"size": 11475,
2584-
"uri": "https://{canondata_backend}/1937492/20dbbb65997057ee913a7da1643b851dbebff2ca/resource.tar.gz#test.test_EquiJoinMap-JoinMap-Debug_/opt.yql"
2582+
"checksum": "22454220ef107b51e9b5a8b81dc82bb5",
2583+
"size": 11355,
2584+
"uri": "https://{canondata_backend}/1597364/857311e8ec9f08c9a1767079dbcac8e2136948e4/resource.tar.gz#test.test_EquiJoinMap-JoinMap-Debug_/opt.yql"
25852585
},
25862586
{
25872587
"checksum": "0f80b02b64f2aa4a39a9765ecefab0f1",
@@ -2686,9 +2686,9 @@
26862686
],
26872687
"test.test[EquiJoinMap-JoinMap-Plan]": [
26882688
{
2689-
"checksum": "f08c4567686936bd71a51cfd8b1a808e",
2690-
"size": 32293,
2691-
"uri": "https://{canondata_backend}/1937492/20dbbb65997057ee913a7da1643b851dbebff2ca/resource.tar.gz#test.test_EquiJoinMap-JoinMap-Plan_/plan.txt"
2689+
"checksum": "9fb035d9c766bc69e1740db85d84ff01",
2690+
"size": 31721,
2691+
"uri": "https://{canondata_backend}/1920236/df054e4be86a61a518eb2517405ce4c923bafedc/resource.tar.gz#test.test_EquiJoinMap-JoinMap-Plan_/plan.txt"
26922692
}
26932693
],
26942694
"test.test[EquiJoinMap-JoinMap-Results]": [
@@ -2700,9 +2700,9 @@
27002700
],
27012701
"test.test[EquiJoinMap-JoinMapOpt1-Debug]": [
27022702
{
2703-
"checksum": "e8b8fb8d2b981433063fbae00d64c6cf",
2704-
"size": 11894,
2705-
"uri": "https://{canondata_backend}/1937492/20dbbb65997057ee913a7da1643b851dbebff2ca/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt1-Debug_/opt.yql"
2703+
"checksum": "8d55802f14c5e93c2147bfd3d9b49605",
2704+
"size": 11774,
2705+
"uri": "https://{canondata_backend}/1775319/da336a036c0a9d0dd564142426be501233a2e3dc/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt1-Debug_/opt.yql"
27062706
},
27072707
{
27082708
"checksum": "0f80b02b64f2aa4a39a9765ecefab0f1",
@@ -2807,9 +2807,9 @@
28072807
],
28082808
"test.test[EquiJoinMap-JoinMapOpt1-Plan]": [
28092809
{
2810-
"checksum": "36498252b46be0415f5c718403a54baa",
2811-
"size": 33193,
2812-
"uri": "https://{canondata_backend}/1937492/20dbbb65997057ee913a7da1643b851dbebff2ca/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt1-Plan_/plan.txt"
2810+
"checksum": "e3d94a46aa264a34bec28c1c37e856e9",
2811+
"size": 32621,
2812+
"uri": "https://{canondata_backend}/1936273/38e8909fc0ff224bb75a20a3ee42c359fa526dbd/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt1-Plan_/plan.txt"
28132813
}
28142814
],
28152815
"test.test[EquiJoinMap-JoinMapOpt1-Results]": [

‎ydb/library/yql/tests/s-expressions/yt_native_file/part4/canondata/result.json

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1035,9 +1035,9 @@
10351035
],
10361036
"test.test[EquiJoin-EquiJoinConvertMapI8U32-Debug]": [
10371037
{
1038-
"checksum": "07df0647cd2720568de2acd1c2f5ac23",
1039-
"size": 18434,
1040-
"uri": "https://{canondata_backend}/1880306/3923e1a600f93542b414a543bc91520fbd3a2554/resource.tar.gz#test.test_EquiJoin-EquiJoinConvertMapI8U32-Debug_/opt.yql"
1038+
"checksum": "ca54ab9b5a671343d62a512410c268c1",
1039+
"size": 18316,
1040+
"uri": "https://{canondata_backend}/1600758/8ae22e8895aeca97699cbfb33bc7979a3bfb8310/resource.tar.gz#test.test_EquiJoin-EquiJoinConvertMapI8U32-Debug_/opt.yql"
10411041
},
10421042
{
10431043
"checksum": "b3ad6c26babf882b76373f6084dbf37c",
@@ -1262,9 +1262,9 @@
12621262
],
12631263
"test.test[EquiJoin-EquiJoinConvertMapI8U32-Plan]": [
12641264
{
1265-
"checksum": "f54da3e0fe9734725763ef7f3ee0a8f0",
1266-
"size": 43842,
1267-
"uri": "https://{canondata_backend}/1931696/343d3ddbf17ce205e67f4b609bbc3d6820c76625/resource.tar.gz#test.test_EquiJoin-EquiJoinConvertMapI8U32-Plan_/plan.txt"
1265+
"checksum": "fd4d3cbbf361c1525902f36a16ecf03e",
1266+
"size": 43270,
1267+
"uri": "https://{canondata_backend}/1937429/9ccaeaa71c2a2536036c2fc5be4d363a086f39f9/resource.tar.gz#test.test_EquiJoin-EquiJoinConvertMapI8U32-Plan_/plan.txt"
12681268
}
12691269
],
12701270
"test.test[EquiJoin-EquiJoinConvertMapI8U32-Results]": [
@@ -2055,9 +2055,9 @@
20552055
],
20562056
"test.test[EquiJoinMap-JoinMapOpt12-Debug]": [
20572057
{
2058-
"checksum": "33945bdfd2af302b24b1d9df58e02660",
2059-
"size": 11419,
2060-
"uri": "https://{canondata_backend}/1936997/7e1c17c15eb7c14c851e4812e1d7a1d1e5ecb4c8/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt12-Debug_/opt.yql"
2058+
"checksum": "3a7e0d7ecf1c6c01b3ce1a587d747111",
2059+
"size": 11370,
2060+
"uri": "https://{canondata_backend}/1942415/69fda1cecc1db727564c082823132d3fb504cfc5/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt12-Debug_/opt.yql"
20612061
},
20622062
{
20632063
"checksum": "e286e591e319776361f0538fbcb207f2",
@@ -2162,9 +2162,9 @@
21622162
],
21632163
"test.test[EquiJoinMap-JoinMapOpt12-Plan]": [
21642164
{
2165-
"checksum": "2abf7a421efb9d665ba0e0e3f74f7dd9",
2166-
"size": 32783,
2167-
"uri": "https://{canondata_backend}/1936997/7e1c17c15eb7c14c851e4812e1d7a1d1e5ecb4c8/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt12-Plan_/plan.txt"
2165+
"checksum": "2e2e956784072772e3a835a767c5f1c2",
2166+
"size": 32497,
2167+
"uri": "https://{canondata_backend}/212715/be64088d0c950974876d778f6923606e08b13081/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt12-Plan_/plan.txt"
21682168
}
21692169
],
21702170
"test.test[EquiJoinMap-JoinMapOpt12-Results]": [

‎ydb/library/yql/tests/s-expressions/yt_native_file/part5/canondata/result.json

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2247,9 +2247,9 @@
22472247
],
22482248
"test.test[EquiJoinMap-JoinMapOpt12Key2-Debug]": [
22492249
{
2250-
"checksum": "972f7cfb59951585e0de61f6a06f1f4d",
2251-
"size": 11551,
2252-
"uri": "https://{canondata_backend}/1937027/9b837c8118f089b56a7bc68568eb0258b2af0bc3/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt12Key2-Debug_/opt.yql"
2250+
"checksum": "0ad6c2319bcd6b396448b9199b8c0e32",
2251+
"size": 11502,
2252+
"uri": "https://{canondata_backend}/1936842/d293e0569b2c9d76735a36d71d28bb6d3f0c9fae/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt12Key2-Debug_/opt.yql"
22532253
},
22542254
{
22552255
"checksum": "d41d8cd98f00b204e9800998ecf8427e",
@@ -2354,9 +2354,9 @@
23542354
],
23552355
"test.test[EquiJoinMap-JoinMapOpt12Key2-Plan]": [
23562356
{
2357-
"checksum": "1985c1fca9e8e1dc20b489ad59f732fe",
2358-
"size": 32845,
2359-
"uri": "https://{canondata_backend}/1937027/9b837c8118f089b56a7bc68568eb0258b2af0bc3/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt12Key2-Plan_/plan.txt"
2357+
"checksum": "e2e310111a7a6a0d5278e5cd559579b6",
2358+
"size": 32559,
2359+
"uri": "https://{canondata_backend}/1920236/3678687df230bd85b22afa78dc31dfe1815b8f9f/resource.tar.gz#test.test_EquiJoinMap-JoinMapOpt12Key2-Plan_/plan.txt"
23602360
}
23612361
],
23622362
"test.test[EquiJoinMap-JoinMapOpt12Key2-Results]": [

0 commit comments

Comments
 (0)