== Physical Plan ==
CollectLimit (5)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- Exchange (4)
+- * Scan ExistingRDD (3)
(1) InMemoryTableScan
Output: []
(2) InMemoryRelation
Arguments: [shardId#21517301, worklistShardItemId#21517302L, version#21517303, product#21517304, plant#21517305, periodStart#21517306, periodEnd#21517307, qty#21517308], StorageLevel(disk, memory, 2 replicas)
(3) Scan ExistingRDD [codegen id : 1]
Output [8]: [shardId#21517301, worklistShardItemId#21517302L, version#21517303, product#21517304, plant#21517305, periodStart#21517306, periodEnd#21517307, qty#21517308]
Arguments: [shardId#21517301, worklistShardItemId#21517302L, version#21517303, product#21517304, plant#21517305, periodStart#21517306, periodEnd#21517307, qty#21517308], SQLExecutionRDD[1241278] at start at FileStorageAdapterImpl.java:174, ExistingRDD, UnknownPartitioning(0)
(4) Exchange
Input [8]: [shardId#21517301, worklistShardItemId#21517302L, version#21517303, product#21517304, plant#21517305, periodStart#21517306, periodEnd#21517307, qty#21517308]
Arguments: hashpartitioning(product#21517304, plant#21517305, 20), REPARTITION_BY_NUM, [plan_id=21255530]
(5) CollectLimit
Input: []
Arguments: 1