digraph G {
0 [labelType="html" label="<br><b>AdaptiveSparkPlan</b><br><br>"];
1 [labelType="html" label="<br><b>DeserializeToObject</b><br><br>"];
2 [labelType="html" label="<b>InMemoryTableScan</b><br><br>number of output rows: 3"];
subgraph cluster3 {
isCluster="true";
label="WholeStageCodegen (1)\n \nduration: 0 ms";
4 [labelType="html" label="<b>Scan JDBCRelation(dbo.fact_style_quantity_details) [numPartitions=1] </b><br><br>number of output rows: 0"];
}
1->0;
2->1;
4->2;
}
5
AdaptiveSparkPlan isFinalPlan=true
DeserializeToObject createexternalrow(buyer_gln#10592915.toString, delivery_quarter#10592916.toString, staticinvoke(class java.lang.Double, ObjectType(class java.lang.Double), valueOf, Style Quantity Traced#10592917, true, false, true), staticinvoke(class java.lang.Double, ObjectType(class java.lang.Double), valueOf, Total Style Quantity in TT#10592918, true, false, true), staticinvoke(class java.lang.Double, ObjectType(class java.lang.Double), valueOf, Total Style Quantity Due for traceability#10592919, true, false, true), staticinvoke(class java.lang.Integer, ObjectType(class java.lang.Integer), valueOf, nike_total_style_quantity#10592920, true, false, true), staticinvoke(class java.lang.Integer, ObjectType(class java.lang.Integer), valueOf, mtz_style_quantity#10592921, true, false, true), StructField(buyer_gln,StringType,true), StructField(delivery_quarter,StringType,true), StructField(Style Quantity Traced,DoubleType,true), StructField(Total Style Quantity in TT,DoubleType,true), StructField(Total Style Quantity Due for traceability,DoubleType,true), StructField(nike_total_style_quantity,IntegerType,true), StructField(mtz_style_quantity,IntegerType,true)), obj#10603839: org.apache.spark.sql.Row
InMemoryTableScan [buyer_gln#10592915, delivery_quarter#10592916, Style Quantity Traced#10592917, Total Style Quantity in TT#10592918, Total Style Quantity Due for traceability#10592919, nike_total_style_quantity#10592920, mtz_style_quantity#10592921]
Scan JDBCRelation(dbo.fact_style_quantity_details) [numPartitions=1] [buyer_gln#10592915,delivery_quarter#10592916,Style Quantity Traced#10592917,Total Style Quantity in TT#10592918,Total Style Quantity Due for traceability#10592919,nike_total_style_quantity#10592920,mtz_style_quantity#10592921] PushedFilters: [], ReadSchema: struct<buyer_gln:string,delivery_quarter:string,Style Quantity Traced:double,Total Style Quantity...
WholeStageCodegen (1)
== Physical Plan ==
AdaptiveSparkPlan (7)
+- == Final Plan ==
DeserializeToObject (5)
+- TableCacheQueryStage (4), Statistics(sizeInBytes=207.0 B, rowCount=3)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- * Scan JDBCRelation(dbo.fact_style_quantity_details) [numPartitions=1] (3)
+- == Initial Plan ==
DeserializeToObject (6)
+- InMemoryTableScan (1)
+- InMemoryRelation (2)
+- * Scan JDBCRelation(dbo.fact_style_quantity_details) [numPartitions=1] (3)
(1) InMemoryTableScan
Output [7]: [buyer_gln#10592915, delivery_quarter#10592916, Style Quantity Traced#10592917, Total Style Quantity in TT#10592918, Total Style Quantity Due for traceability#10592919, nike_total_style_quantity#10592920, mtz_style_quantity#10592921]
Arguments: [buyer_gln#10592915, delivery_quarter#10592916, Style Quantity Traced#10592917, Total Style Quantity in TT#10592918, Total Style Quantity Due for traceability#10592919, nike_total_style_quantity#10592920, mtz_style_quantity#10592921]
(2) InMemoryRelation
Arguments: [buyer_gln#10592915, delivery_quarter#10592916, Style Quantity Traced#10592917, Total Style Quantity in TT#10592918, Total Style Quantity Due for traceability#10592919, nike_total_style_quantity#10592920, mtz_style_quantity#10592921], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@7795a5ad,StorageLevel(disk, memory, deserialized, 1 replicas),*(1) Scan JDBCRelation(dbo.fact_style_quantity_details) [numPartitions=1] [buyer_gln#10592915,delivery_quarter#10592916,Style Quantity Traced#10592917,Total Style Quantity in TT#10592918,Total Style Quantity Due for traceability#10592919,nike_total_style_quantity#10592920,mtz_style_quantity#10592921] PushedFilters: [], ReadSchema: struct<buyer_gln:string,delivery_quarter:string,Style Quantity Traced:double,Total Style Quantity...
,None)
(3) Scan JDBCRelation(dbo.fact_style_quantity_details) [numPartitions=1] [codegen id : 1]
Output [7]: [buyer_gln#10592915, delivery_quarter#10592916, Style Quantity Traced#10592917, Total Style Quantity in TT#10592918, Total Style Quantity Due for traceability#10592919, nike_total_style_quantity#10592920, mtz_style_quantity#10592921]
ReadSchema: struct<buyer_gln:string,delivery_quarter:string,Style Quantity Traced:double,Total Style Quantity in TT:double,Total Style Quantity Due for traceability:double,nike_total_style_quantity:int,mtz_style_quantity:int>
(4) TableCacheQueryStage
Output [7]: [buyer_gln#10592915, delivery_quarter#10592916, Style Quantity Traced#10592917, Total Style Quantity in TT#10592918, Total Style Quantity Due for traceability#10592919, nike_total_style_quantity#10592920, mtz_style_quantity#10592921]
Arguments: 0
(5) DeserializeToObject
Input [7]: [buyer_gln#10592915, delivery_quarter#10592916, Style Quantity Traced#10592917, Total Style Quantity in TT#10592918, Total Style Quantity Due for traceability#10592919, nike_total_style_quantity#10592920, mtz_style_quantity#10592921]
Arguments: createexternalrow(buyer_gln#10592915.toString, delivery_quarter#10592916.toString, staticinvoke(class java.lang.Double, ObjectType(class java.lang.Double), valueOf, Style Quantity Traced#10592917, true, false, true), staticinvoke(class java.lang.Double, ObjectType(class java.lang.Double), valueOf, Total Style Quantity in TT#10592918, true, false, true), staticinvoke(class java.lang.Double, ObjectType(class java.lang.Double), valueOf, Total Style Quantity Due for traceability#10592919, true, false, true), staticinvoke(class java.lang.Integer, ObjectType(class java.lang.Integer), valueOf, nike_total_style_quantity#10592920, true, false, true), staticinvoke(class java.lang.Integer, ObjectType(class java.lang.Integer), valueOf, mtz_style_quantity#10592921, true, false, true), StructField(buyer_gln,StringType,true), StructField(delivery_quarter,StringType,true), StructField(Style Quantity Traced,DoubleType,true), StructField(Total Style Quantity in TT,DoubleType,true), StructField(Total Style Quantity Due for traceability,DoubleType,true), StructField(nike_total_style_quantity,IntegerType,true), StructField(mtz_style_quantity,IntegerType,true)), obj#10603839: org.apache.spark.sql.Row
(6) DeserializeToObject
Input [7]: [buyer_gln#10592915, delivery_quarter#10592916, Style Quantity Traced#10592917, Total Style Quantity in TT#10592918, Total Style Quantity Due for traceability#10592919, nike_total_style_quantity#10592920, mtz_style_quantity#10592921]
Arguments: createexternalrow(buyer_gln#10592915.toString, delivery_quarter#10592916.toString, staticinvoke(class java.lang.Double, ObjectType(class java.lang.Double), valueOf, Style Quantity Traced#10592917, true, false, true), staticinvoke(class java.lang.Double, ObjectType(class java.lang.Double), valueOf, Total Style Quantity in TT#10592918, true, false, true), staticinvoke(class java.lang.Double, ObjectType(class java.lang.Double), valueOf, Total Style Quantity Due for traceability#10592919, true, false, true), staticinvoke(class java.lang.Integer, ObjectType(class java.lang.Integer), valueOf, nike_total_style_quantity#10592920, true, false, true), staticinvoke(class java.lang.Integer, ObjectType(class java.lang.Integer), valueOf, mtz_style_quantity#10592921, true, false, true), StructField(buyer_gln,StringType,true), StructField(delivery_quarter,StringType,true), StructField(Style Quantity Traced,DoubleType,true), StructField(Total Style Quantity in TT,DoubleType,true), StructField(Total Style Quantity Due for traceability,DoubleType,true), StructField(nike_total_style_quantity,IntegerType,true), StructField(mtz_style_quantity,IntegerType,true)), obj#10603839: org.apache.spark.sql.Row
(7) AdaptiveSparkPlan
Output [1]: [obj#10603839]
Arguments: isFinalPlan=true