digraph G {
subgraph clusterstage_530 {
label="Stage 530";
2043 [labelType="html" label="JDBCRDD [2043]<br>cache at ValueReplaceNode.java:62"];
2105 [labelType="html" label="SQLExecutionRDD [2105]<br>foreachPartition at SparkFunctionUtil.java:146"];
subgraph cluster4948 {
label="WholeStageCodegen (1)";
2044 [labelType="html" label="MapPartitionsRDD [2044]<br>count at DatasetOutput.java:65"];
}
subgraph cluster4947 {
label="Generate";
2045 [labelType="html" label="MapPartitionsRDD [2045]<br>count at DatasetOutput.java:65"];
}
subgraph cluster4942 {
label="WholeStageCodegen (2)";
2046 [labelType="html" label="MapPartitionsRDD [2046]<br>count at DatasetOutput.java:65"];
}
subgraph cluster4941 {
label="InMemoryTableScan";
2047 [labelType="html" label="MapPartitionsRDD [2047]<br>count at DatasetOutput.java:65"];
2048 [labelType="html" label="*(2) 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, F0000080), StringType), true, false) AS F0000080#21078, 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, ye), StringType), true, false) AS ye#21079, 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]), 2, dataTime), StringType), true, false) AS dataTime#21080, if (assertnotnull(input[0, org.apache.spa... [2048] [Cached]<br>count at DatasetOutput.java:65"];
}
subgraph cluster5070 {
label="InMemoryTableScan";
2100 [labelType="html" label="MapPartitionsRDD [2100]<br>foreachPartition at SparkFunctionUtil.java:146"];
2101 [labelType="html" label="MapPartitionsRDD [2101]<br>foreachPartition at SparkFunctionUtil.java:146"];
2102 [labelType="html" label="MapPartitionsRDD [2102]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster5067 {
label="WholeStageCodegen (1)";
2103 [labelType="html" label="MapPartitionsRDD [2103]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster5066 {
label="DeserializeToObject";
2104 [labelType="html" label="MapPartitionsRDD [2104]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster5071 {
label="mapPartitions";
2106 [labelType="html" label="MapPartitionsRDD [2106]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
}
2043->2044;
2044->2045;
2045->2046;
2046->2047;
2047->2048;
2048->2100;
2100->2101;
2101->2102;
2102->2103;
2103->2104;
2104->2105;
2105->2106;
}
2048