== Physical Plan ==
CollectLimit (8)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- * Project (7)
+- * Generate (6)
+- * Project (5)
+- * Filter (4)
+- * Scan ExistingRDD (3)
(1) InMemoryTableScan
Output: []
(2) InMemoryRelation
Arguments: [shardId#5564008, worklistShardItemId#5564017L], StorageLevel(disk, memory, 2 replicas)
(3) Scan ExistingRDD [codegen id : 1]
Output [7]: [shardId#5564008, orderProposalId#5564009L, items#5564010, optimizationGroups#5564011, isOptimal#5564012, lastModified#5564013, optimizationInsights#5564014]
Arguments: [shardId#5564008, orderProposalId#5564009L, items#5564010, optimizationGroups#5564011, isOptimal#5564012, lastModified#5564013, optimizationInsights#5564014], MapPartitionsRDD[391500] at start at FileStorageAdapterImpl.java:598, ExistingRDD, UnknownPartitioning(0)
(4) Filter [codegen id : 1]
Input [7]: [shardId#5564008, orderProposalId#5564009L, items#5564010, optimizationGroups#5564011, isOptimal#5564012, lastModified#5564013, optimizationInsights#5564014]
Condition : ((isnotnull(shardId#5564008) AND ((shardId#5564008 = 0_1_10000001445) AND (isOptimal#5564012 <=> false))) AND ((size(items#5564010.worklistShardItemId, true) > 0) AND isnotnull(items#5564010.worklistShardItemId)))
(5) Project [codegen id : 1]
Output [2]: [shardId#5564008, items#5564010.worklistShardItemId AS _extract_worklistShardItemId#5564020]
Input [7]: [shardId#5564008, orderProposalId#5564009L, items#5564010, optimizationGroups#5564011, isOptimal#5564012, lastModified#5564013, optimizationInsights#5564014]
(6) Generate [codegen id : 1]
Input [2]: [shardId#5564008, _extract_worklistShardItemId#5564020]
Arguments: explode(_extract_worklistShardItemId#5564020), [shardId#5564008], false, [item#5564016L]
(7) Project [codegen id : 1]
Output [2]: [shardId#5564008, item#5564016L AS worklistShardItemId#5564017L]
Input [2]: [shardId#5564008, item#5564016L]
(8) CollectLimit
Input: []
Arguments: 1