digraph G {
0 [id="node0" labelType="html" label="<b>Execute InsertIntoHadoopFsRelationCommand</b><br><br>task commit time: 249 ms<br>number of written files: 1<br>job commit time: 376 ms<br>number of output rows: 0<br>number of dynamic part: 0<br>written output: 1267.0 B" tooltip="Execute InsertIntoHadoopFsRelationCommand hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/prp-op-traceability-results/raw/crp-order-quantity-kpi-service/ogr/10000000539/0_1_10000000539, false, Parquet, [path=hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/prp-op-traceability-results/raw/crp-order-quantity-kpi-service/ogr/10000000539/0_1_10000000539], Append, [product, location, documents, replenishmentRunId]"];
1 [id="node1" labelType="html" label="<br><b>WriteFiles</b><br><br>" tooltip="WriteFiles"];
2 [id="node2" labelType="html" label="<br><b>Project</b><br><br>" tooltip="Project [product#13793785, plant#13793784 AS location#13801954, transform(openGoodsMovements#13793886, lambdafunction(struct(documentId, lambda x_1027#13801957.documentId, documentUuid, lambda x_1027#13801957.documentUuid, openQty, lambda x_1027#13801957.openQty, qtyUomUuid, lambda x_1027#13801957.qtyUomUuid, qtyUom, lambda x_1027#13801957.qtyUom, plannedDeliveryDatetime, lambda x_1027#13801957.availabilityDatetime), lambda x_1027#13801957, false)) AS documents#13801956, 10000000539 AS replenishmentRunId#13801958L]"];
3 [id="node3" labelType="html" label="<br><b>Filter</b><br><br>" tooltip="Filter (size(transform(openGoodsMovements#13793886, lambdafunction(struct(documentId, lambda x_1027#13801957.documentId, documentUuid, lambda x_1027#13801957.documentUuid, openQty, lambda x_1027#13801957.openQty, qtyUomUuid, lambda x_1027#13801957.qtyUomUuid, qtyUom, lambda x_1027#13801957.qtyUom, plannedDeliveryDatetime, lambda x_1027#13801957.availabilityDatetime), lambda x_1027#13801957, false)), false) > 0)"];
4 [id="node4" labelType="html" label="<br><b>InMemoryTableScan</b><br><br>" tooltip="InMemoryTableScan [openGoodsMovements#13793886, plant#13793784, product#13793785], [(size(transform(openGoodsMovements#13793886, lambdafunction(struct(documentId, lambda x_1027#13801957.documentId, documentUuid, lambda x_1027#13801957.documentUuid, openQty, lambda x_1027#13801957.openQty, qtyUomUuid, lambda x_1027#13801957.qtyUomUuid, qtyUom, lambda x_1027#13801957.qtyUom, plannedDeliveryDatetime, lambda x_1027#13801957.availabilityDatetime), lambda x_1027#13801957, false)), false) > 0)]"];
5 [id="node5" labelType="html" label="<br><b>LocalTableScan</b><br><br>" tooltip="LocalTableScan <empty>, [product#13793785, plant#13793784, openGoodsMovements#13793886]"];
1->0;
2->1;
3->2;
4->3;
5->4;
}
== Physical Plan ==
Execute InsertIntoHadoopFsRelationCommand (7)
+- WriteFiles (6)
+- Project (5)
+- Filter (4)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- LocalTableScan (3)
(1) InMemoryTableScan
Output [3]: [openGoodsMovements#13793886, plant#13793784, product#13793785]
Arguments: [openGoodsMovements#13793886, plant#13793784, product#13793785], [(size(transform(openGoodsMovements#13793886, lambdafunction(struct(documentId, lambda x_1027#13801957.documentId, documentUuid, lambda x_1027#13801957.documentUuid, openQty, lambda x_1027#13801957.openQty, qtyUomUuid, lambda x_1027#13801957.qtyUomUuid, qtyUom, lambda x_1027#13801957.qtyUom, plannedDeliveryDatetime, lambda x_1027#13801957.availabilityDatetime), lambda x_1027#13801957, false)), false) > 0)]
(2) InMemoryRelation
Arguments: [product#13793785, plant#13793784, openGoodsMovements#13793886], StorageLevel(disk, memory, 2 replicas)
(3) LocalTableScan
Output [3]: [product#13793785, plant#13793784, openGoodsMovements#13793886]
Arguments: <empty>, [product#13793785, plant#13793784, openGoodsMovements#13793886]
(4) Filter
Input [3]: [openGoodsMovements#13793886, plant#13793784, product#13793785]
Condition : (size(transform(openGoodsMovements#13793886, lambdafunction(struct(documentId, lambda x_1027#13801957.documentId, documentUuid, lambda x_1027#13801957.documentUuid, openQty, lambda x_1027#13801957.openQty, qtyUomUuid, lambda x_1027#13801957.qtyUomUuid, qtyUom, lambda x_1027#13801957.qtyUom, plannedDeliveryDatetime, lambda x_1027#13801957.availabilityDatetime), lambda x_1027#13801957, false)), false) > 0)
(5) Project
Output [4]: [product#13793785, plant#13793784 AS location#13801954, transform(openGoodsMovements#13793886, lambdafunction(struct(documentId, lambda x_1027#13801957.documentId, documentUuid, lambda x_1027#13801957.documentUuid, openQty, lambda x_1027#13801957.openQty, qtyUomUuid, lambda x_1027#13801957.qtyUomUuid, qtyUom, lambda x_1027#13801957.qtyUom, plannedDeliveryDatetime, lambda x_1027#13801957.availabilityDatetime), lambda x_1027#13801957, false)) AS documents#13801956, 10000000539 AS replenishmentRunId#13801958L]
Input [3]: [openGoodsMovements#13793886, plant#13793784, product#13793785]
(6) WriteFiles
Input [4]: [product#13793785, location#13801954, documents#13801956, replenishmentRunId#13801958L]
(7) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/prp-op-traceability-results/raw/crp-order-quantity-kpi-service/ogr/10000000539/0_1_10000000539, false, Parquet, [path=hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/prp-op-traceability-results/raw/crp-order-quantity-kpi-service/ogr/10000000539/0_1_10000000539], Append, [product, location, documents, replenishmentRunId]