== Physical Plan ==
Execute SaveIntoDataSourceCommand (1)
+- SaveIntoDataSourceCommand (2)
+- Project (7)
+- Join (6)
:- Filter (4)
: +- LogicalRDD (3)
+- LocalRelation (5)
(1) Execute SaveIntoDataSourceCommand
Output: []
(2) SaveIntoDataSourceCommand
Arguments: org.apache.spark.sql.delta.sources.DeltaDataSource@2f2efa92, [__partition_columns=["shardId","sequenceId"], path=hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/kpi-curve-cache/10000001445], Overwrite
(3) LogicalRDD
Arguments: [shardId#5604426, worklistShardItemId#5604427L, qty#5604428, demandChannel#5604429, demandStream#5604430, kpis#5604431], false
(4) Filter
Arguments: shardId#5604426 IN (0_1_10000001445)
(5) LocalRelation
Arguments: [shardId#5604435, sequenceId#5604436]
(6) Join
Arguments: Inner, (shardId#5604426 = shardId#5604435)
(7) Project
Arguments: [shardId#5604426, worklistShardItemId#5604427L, qty#5604428, demandChannel#5604429, demandStream#5604430, kpis#5604431, sequenceId#5604436]