digraph G {
subgraph clusterstage_402 {
label="Stage 402";
subgraph cluster2834 {
label="Exchange";
1057 [labelType="html" label="ShuffledRowRDD [1057] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster2828 {
label="AdaptiveSparkPlan";
1058 [labelType="html" label="MapPartitionsRDD [1058] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
1059 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Exchange SinglePartition, REPARTITION_BY_NUM, [plan_id=11089]\n +- InMemoryTableScan [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, product#32783, orderDateTime#32784, availabilityDateTime#32785, nextAvailabilityDateTime#32786, mrpController#32787, sourceOfSupplyUuid#32788, purchasingOrg#32789, purchasingGroup#32790, orderProposalId#33183L, orderProposalHorizonGroupingId#33204L, splitIndicator#33604L]\n +- InMemoryRelation [supplierGroup#32467, supplier#32468, plant#32469, deliveryDateTime#32470, subrange#32471, product#32783, orderDateTime#32784, availabilityDateTime#32785, nextAvailabilityDateTime#32786, mrpController#32787, sourceOfSupplyUuid#32788, purchasingOrg#32789, purchasingGroup#32790, orderProposalId#33183L, orderProposalHorizonGroupingId#33204L, splitIndicator#33604L], StorageLevel(disk, memory, 2 replicas)\n +- AdaptiveSparkPlan isFinalPlan=true\n +- == Final Plan ==\n ... [1059] [Cached] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster2841 {
label="InMemoryTableScan";
1060 [labelType="html" label="MapPartitionsRDD [1060] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
1061 [labelType="html" label="MapPartitionsRDD [1061] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
1062 [labelType="html" label="MapPartitionsRDD [1062] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster2839 {
label="DeserializeToObject";
1063 [labelType="html" label="MapPartitionsRDD [1063] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster2838 {
label="MapPartitions";
1064 [labelType="html" label="MapPartitionsRDD [1064] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster2835 {
label="WholeStageCodegen (1)";
1065 [labelType="html" label="MapPartitionsRDD [1065] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster2827 {
label="AdaptiveSparkPlan";
1066 [labelType="html" label="MapPartitionsRDD [1066] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
1067 [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#35312, 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#35313, 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(inp... [1067] [Cached] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster2847 {
label="InMemoryTableScan";
1068 [labelType="html" label="MapPartitionsRDD [1068] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
1069 [labelType="html" label="MapPartitionsRDD [1069] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
1070 [labelType="html" label="MapPartitionsRDD [1070] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster2842 {
label="WholeStageCodegen (1)";
1071 [labelType="html" label="MapPartitionsRDD [1071] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster2848 {
label="mapPartitionsInternal";
1072 [labelType="html" label="MapPartitionsRDD [1072] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
subgraph cluster2849 {
label="mapPartitionsInternal";
1073 [labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [supplierGroup#35312, supplier#35313, plant#35314, deliveryDateTime#35315, subrange#35316, product#35317, orderDateTime#35318, availabilityDateTime#35319, nextAvailabilityDateTime#35320, mrpController#35321, sourceOfSupplyUuid#35322, purchasingOrg#35323, purchasingGroup#35324, orderProposalId#35325L, orderProposalHorizonGroupingId#35326L, splitIndicator#35327L, shardId#35654, worklistShardItemId#35690L, null AS orderProposalItemGroupId#35709, cast((monotonically_increasing_id() % 9999999999) as string) AS orderProposalItemId#35729]\n +- Project [supplierGroup#35312, supplier#35313, plant#35314, deliveryDateTime#35315, subrange#35316, product#35317, orderDateTime#35318, availabilityDateTime#35319, nextAvailabilityDateTime#35320, mrpController#35321, sourceOfSupplyUuid#35322, purchasingOrg#35323, purchasingGroup#35324, orderProposalId#35325L, orderProposalHorizonGroupingId#35326L, splitIndicator#35327L, concat(0, _, cast(binId#35328 as string), _, 10000000096) ... [1073] [Cached] [Unordered]<br>collectAsList at FileStorageAdapterImpl.java:260"];
}
}
1057->1058;
1058->1059;
1059->1060;
1060->1061;
1061->1062;
1062->1063;
1063->1064;
1064->1065;
1065->1066;
1066->1067;
1067->1068;
1068->1069;
1069->1070;
1070->1071;
1071->1072;
1072->1073;
}
1056,1057
1059
1067
1073