digraph G {
subgraph clusterstage_99 {
label="Stage 99";
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"];
}
subgraph cluster612 {
label="InMemoryTableScan";
226 [labelType="html" label="MapPartitionsRDD [226] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
227 [labelType="html" label="MapPartitionsRDD [227] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
228 [labelType="html" label="MapPartitionsRDD [228] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster607 {
label="WholeStageCodegen (1)";
229 [labelType="html" label="MapPartitionsRDD [229] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster613 {
label="mapPartitionsInternal";
230 [labelType="html" label="MapPartitionsRDD [230] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster614 {
label="mapPartitionsInternal";
231 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [supplierGroup#5844, supplier#5845, plant#5846, deliveryDateTime#5847, subrange#5848, product#5849, orderDateTime#5850, availabilityDateTime#5851, nextAvailabilityDateTime#5852, mrpController#5853, sourceOfSupplyUuid#5854, purchasingOrg#5855, purchasingGroup#5856, orderProposalId#5857L, orderProposalHorizonGroupingId#5858L, splitIndicator#5859L, shardId#6186, worklistShardItemId#6222L, null AS orderProposalItemGroupId#6241, cast((monotonically_increasing_id() % 9999999999) as string) AS orderProposalItemId#6261]\n +- Project [supplierGroup#5844, supplier#5845, plant#5846, deliveryDateTime#5847, subrange#5848, product#5849, orderDateTime#5850, availabilityDateTime#5851, nextAvailabilityDateTime#5852, mrpController#5853, sourceOfSupplyUuid#5854, purchasingOrg#5855, purchasingGroup#5856, orderProposalId#5857L, orderProposalHorizonGroupingId#5858L, splitIndicator#5859L, concat(0, _, cast(binId#5860 as string), _, 10000000095) AS shardId#6186, monotonically_increa... [231] [Cached] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster652 {
label="InMemoryTableScan";
237 [labelType="html" label="MapPartitionsRDD [237] [Unordered]<br>save at FileStorageAdapterImpl.java:250"];
238 [labelType="html" label="MapPartitionsRDD [238] [Unordered]<br>save at FileStorageAdapterImpl.java:250"];
239 [labelType="html" label="MapPartitionsRDD [239] [Unordered]<br>save at FileStorageAdapterImpl.java:250"];
}
subgraph cluster650 {
label="Exchange";
240 [labelType="html" label="MapPartitionsRDD [240] [Unordered]<br>save at FileStorageAdapterImpl.java:250"];
}
}
215->216;
216->217;
217->218;
218->219;
219->220;
220->221;
221->222;
222->223;
223->224;
224->225;
225->226;
226->227;
227->228;
228->229;
229->230;
230->231;
231->237;
237->238;
238->239;
239->240;
}
214,215
217
225
231