digraph G {
subgraph clusterstage_87 {
label="Stage 87";
subgraph cluster599 {
label="Exchange";
215 [labelType="html" label="ShuffledRowRDD [215] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster593 {
label="AdaptiveSparkPlan";
216 [labelType="html" label="MapPartitionsRDD [216] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
217 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=2208]\n +- InMemoryTableScan [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, product#3315, orderDateTime#3316, availabilityDateTime#3317, nextAvailabilityDateTime#3318, mrpController#3319, sourceOfSupplyUuid#3320, purchasingOrg#3321, purchasingGroup#3322, orderProposalId#3715L, orderProposalHorizonGroupingId#3736L, splitIndicator#4136L]\n +- InMemoryRelation [supplierGroup#2999, supplier#3000, plant#3001, deliveryDateTime#3002, subrange#3003, product#3315, orderDateTime#3316, availabilityDateTime#3317, nextAvailabilityDateTime#3318, mrpController#3319, sourceOfSupplyUuid#3320, purchasingOrg#3321, purchasingGroup#3322, orderProposalId#3715L, orderProposalHorizonGroupingId#3736L, splitIndicator#4136L], StorageLevel(disk, memory, 2 replicas)\n +- AdaptiveSparkPlan isFinalPlan=true\n +- == Final Plan ==\n *(5) Project [suppli... [217] [Cached] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster606 {
label="InMemoryTableScan";
218 [labelType="html" label="MapPartitionsRDD [218] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
219 [labelType="html" label="MapPartitionsRDD [219] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
220 [labelType="html" label="MapPartitionsRDD [220] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster604 {
label="DeserializeToObject";
221 [labelType="html" label="MapPartitionsRDD [221] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster603 {
label="MapPartitions";
222 [labelType="html" label="MapPartitionsRDD [222] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster600 {
label="WholeStageCodegen (1)";
223 [labelType="html" label="MapPartitionsRDD [223] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster592 {
label="AdaptiveSparkPlan";
224 [labelType="html" label="MapPartitionsRDD [224] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
225 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- SerializeFromObject [if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 0, supplierGroup), StringType, ObjectType(class java.lang.String)), true, false, true) AS supplierGroup#5844, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 1, supplier), StringType, ObjectType(class java.lang.String)), true, false, true) AS supplier#5845, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input... [225] [Cached] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
}
215->216;
216->217;
217->218;
218->219;
219->220;
220->221;
221->222;
222->223;
223->224;
224->225;
}
214,215
217
225