|
5318 | 5318 | <span class="gp">>>> </span><span class="nb">print</span><span class="p">(</span><span class="n">analysis</span><span class="p">)</span> |
5319 | 5319 | <span class="go"> MergeInsert: elapsed=..., on=[id], ..., metrics=[..., bytes_written=..., ...]</span> |
5320 | 5320 | <span class="go"> CoalescePartitionsExec, elapsed=..., metrics=[output_rows=..., elapsed_compute=...]</span> |
5321 | | -<span class="go"> ProjectionExec: elapsed=..., expr=[_rowid@1 as _rowid, ...], metrics=[...]</span> |
5322 | | -<span class="go"> ProjectionExec: elapsed=..., expr=[id@2 IS NOT NULL as __common_expr_1, ...], metrics=[...]</span> |
5323 | | -<span class="go"> HashJoinExec: elapsed=..., mode=CollectLeft, join_type=Right, ...</span> |
5324 | | -<span class="go"> CooperativeExec, elapsed=..., metrics=[]</span> |
5325 | | -<span class="go"> LanceRead: elapsed=..., ..., metrics=[..., bytes_read=..., ...]</span> |
5326 | | -<span class="go"> RepartitionExec: ...</span> |
| 5321 | +<span class="go"> ProjectionExec: elapsed=..., expr=[...], metrics=[...]</span> |
| 5322 | +<span class="go"> HashJoinExec: elapsed=..., mode=CollectLeft, join_type=Right, ...</span> |
| 5323 | +<span class="go"> CooperativeExec, elapsed=..., metrics=[]</span> |
| 5324 | +<span class="go"> LanceRead: elapsed=..., ..., metrics=[..., bytes_read=..., ...]</span> |
| 5325 | +<span class="go"> RepartitionExec: ...</span> |
| 5326 | +<span class="go"> ProjectionExec: elapsed=..., expr=[..., true as __merge_source_sentinel], metrics=[...]</span> |
5327 | 5327 | <span class="go"> StreamingTableExec: ..., metrics=[]</span> |
5328 | 5328 | </pre></div> |
5329 | 5329 | </div> |
|
5435 | 5435 | <span class="gp">>>> </span><span class="nb">print</span><span class="p">(</span><span class="n">plan</span><span class="p">)</span> |
5436 | 5436 | <span class="go">MergeInsert: on=[id], when_matched=UpdateAll, when_not_matched=InsertAll, ...</span> |
5437 | 5437 | <span class="go"> CoalescePartitionsExec</span> |
5438 | | -<span class="go"> ProjectionExec: expr=[_rowid@1 as _rowid, _rowaddr@2 as _rowaddr, ...]</span> |
5439 | | -<span class="go"> ProjectionExec: expr=[id@2 IS NOT NULL as __common_expr_1, ...]</span> |
5440 | | -<span class="go"> HashJoinExec: mode=CollectLeft, join_type=Right, ...</span> |
5441 | | -<span class="go"> CooperativeExec</span> |
5442 | | -<span class="go"> LanceRead: uri=test_dataset/data, projection=[id], ...</span> |
5443 | | -<span class="go"> RepartitionExec: ...</span> |
| 5438 | +<span class="go"> ProjectionExec: expr=[...]</span> |
| 5439 | +<span class="go"> HashJoinExec: mode=CollectLeft, join_type=Right, ...</span> |
| 5440 | +<span class="go"> CooperativeExec</span> |
| 5441 | +<span class="go"> LanceRead: uri=test_dataset/data, projection=[id], ...</span> |
| 5442 | +<span class="go"> RepartitionExec: ...</span> |
| 5443 | +<span class="go"> ProjectionExec: expr=[..., true as __merge_source_sentinel]</span> |
5444 | 5444 | <span class="go"> StreamingTableExec: partition_sizes=1, ...</span> |
5445 | 5445 | </pre></div> |
5446 | 5446 | </div> |
|
5454 | 5454 | <span class="gp">>>> </span><span class="nb">print</span><span class="p">(</span><span class="n">plan</span><span class="p">)</span> |
5455 | 5455 | <span class="go">MergeInsert: on=[id], when_matched=UpdateAll, when_not_matched=InsertAll, ...</span> |
5456 | 5456 | <span class="go"> CoalescePartitionsExec</span> |
5457 | | -<span class="go"> ProjectionExec: expr=[_rowid@1 as _rowid, _rowaddr@2 as _rowaddr, ...]</span> |
5458 | | -<span class="go"> ProjectionExec: expr=[id@2 IS NOT NULL as __common_expr_1, ...]</span> |
5459 | | -<span class="go"> HashJoinExec: mode=CollectLeft, join_type=Right, ...</span> |
5460 | | -<span class="go"> ...</span> |
| 5457 | +<span class="go"> ProjectionExec: expr=[...]</span> |
| 5458 | +<span class="go"> HashJoinExec: mode=CollectLeft, join_type=Right, ...</span> |
| 5459 | +<span class="go"> ...</span> |
5461 | 5460 | </pre></div> |
5462 | 5461 | </div> |
5463 | 5462 | </dd></dl> |
|
9608 | 9607 | <span class="gp">>>> </span><span class="nb">print</span><span class="p">(</span><span class="n">analysis</span><span class="p">)</span> |
9609 | 9608 | <span class="go"> MergeInsert: elapsed=..., on=[id], ..., metrics=[..., bytes_written=..., ...]</span> |
9610 | 9609 | <span class="go"> CoalescePartitionsExec, elapsed=..., metrics=[output_rows=..., elapsed_compute=...]</span> |
9611 | | -<span class="go"> ProjectionExec: elapsed=..., expr=[_rowid@1 as _rowid, ...], metrics=[...]</span> |
9612 | | -<span class="go"> ProjectionExec: elapsed=..., expr=[id@2 IS NOT NULL as __common_expr_1, ...], metrics=[...]</span> |
9613 | | -<span class="go"> HashJoinExec: elapsed=..., mode=CollectLeft, join_type=Right, ...</span> |
9614 | | -<span class="go"> CooperativeExec, elapsed=..., metrics=[]</span> |
9615 | | -<span class="go"> LanceRead: elapsed=..., ..., metrics=[..., bytes_read=..., ...]</span> |
9616 | | -<span class="go"> RepartitionExec: ...</span> |
| 9610 | +<span class="go"> ProjectionExec: elapsed=..., expr=[...], metrics=[...]</span> |
| 9611 | +<span class="go"> HashJoinExec: elapsed=..., mode=CollectLeft, join_type=Right, ...</span> |
| 9612 | +<span class="go"> CooperativeExec, elapsed=..., metrics=[]</span> |
| 9613 | +<span class="go"> LanceRead: elapsed=..., ..., metrics=[..., bytes_read=..., ...]</span> |
| 9614 | +<span class="go"> RepartitionExec: ...</span> |
| 9615 | +<span class="go"> ProjectionExec: elapsed=..., expr=[..., true as __merge_source_sentinel], metrics=[...]</span> |
9617 | 9616 | <span class="go"> StreamingTableExec: ..., metrics=[]</span> |
9618 | 9617 | </pre></div> |
9619 | 9618 | </div> |
|
9725 | 9724 | <span class="gp">>>> </span><span class="nb">print</span><span class="p">(</span><span class="n">plan</span><span class="p">)</span> |
9726 | 9725 | <span class="go">MergeInsert: on=[id], when_matched=UpdateAll, when_not_matched=InsertAll, ...</span> |
9727 | 9726 | <span class="go"> CoalescePartitionsExec</span> |
9728 | | -<span class="go"> ProjectionExec: expr=[_rowid@1 as _rowid, _rowaddr@2 as _rowaddr, ...]</span> |
9729 | | -<span class="go"> ProjectionExec: expr=[id@2 IS NOT NULL as __common_expr_1, ...]</span> |
9730 | | -<span class="go"> HashJoinExec: mode=CollectLeft, join_type=Right, ...</span> |
9731 | | -<span class="go"> CooperativeExec</span> |
9732 | | -<span class="go"> LanceRead: uri=test_dataset/data, projection=[id], ...</span> |
9733 | | -<span class="go"> RepartitionExec: ...</span> |
| 9727 | +<span class="go"> ProjectionExec: expr=[...]</span> |
| 9728 | +<span class="go"> HashJoinExec: mode=CollectLeft, join_type=Right, ...</span> |
| 9729 | +<span class="go"> CooperativeExec</span> |
| 9730 | +<span class="go"> LanceRead: uri=test_dataset/data, projection=[id], ...</span> |
| 9731 | +<span class="go"> RepartitionExec: ...</span> |
| 9732 | +<span class="go"> ProjectionExec: expr=[..., true as __merge_source_sentinel]</span> |
9734 | 9733 | <span class="go"> StreamingTableExec: partition_sizes=1, ...</span> |
9735 | 9734 | </pre></div> |
9736 | 9735 | </div> |
|
9744 | 9743 | <span class="gp">>>> </span><span class="nb">print</span><span class="p">(</span><span class="n">plan</span><span class="p">)</span> |
9745 | 9744 | <span class="go">MergeInsert: on=[id], when_matched=UpdateAll, when_not_matched=InsertAll, ...</span> |
9746 | 9745 | <span class="go"> CoalescePartitionsExec</span> |
9747 | | -<span class="go"> ProjectionExec: expr=[_rowid@1 as _rowid, _rowaddr@2 as _rowaddr, ...]</span> |
9748 | | -<span class="go"> ProjectionExec: expr=[id@2 IS NOT NULL as __common_expr_1, ...]</span> |
9749 | | -<span class="go"> HashJoinExec: mode=CollectLeft, join_type=Right, ...</span> |
9750 | | -<span class="go"> ...</span> |
| 9746 | +<span class="go"> ProjectionExec: expr=[...]</span> |
| 9747 | +<span class="go"> HashJoinExec: mode=CollectLeft, join_type=Right, ...</span> |
| 9748 | +<span class="go"> ...</span> |
9751 | 9749 | </pre></div> |
9752 | 9750 | </div> |
9753 | 9751 | </dd></dl> |
|
0 commit comments