digraph G {
subgraph clusterstage_986 {
label="Stage 986";
3855 [labelType="html" label="JDBCRDD [3855]<br>cache at ValueReplaceNode.java:62"];
3917 [labelType="html" label="SQLExecutionRDD [3917]<br>foreachPartition at SparkFunctionUtil.java:146"];
subgraph cluster9316 {
label="WholeStageCodegen (1)";
3856 [labelType="html" label="MapPartitionsRDD [3856]<br>count at DatasetOutput.java:65"];
}
subgraph cluster9315 {
label="Generate";
3857 [labelType="html" label="MapPartitionsRDD [3857]<br>count at DatasetOutput.java:65"];
}
subgraph cluster9310 {
label="WholeStageCodegen (2)";
3858 [labelType="html" label="MapPartitionsRDD [3858]<br>count at DatasetOutput.java:65"];
}
subgraph cluster9309 {
label="InMemoryTableScan";
3859 [labelType="html" label="MapPartitionsRDD [3859]<br>count at DatasetOutput.java:65"];
3860 [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#40278, 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#40279, 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#40280, if (assertnotnull(input[0, org.apache.spa... [3860] [Cached]<br>count at DatasetOutput.java:65"];
}
subgraph cluster9438 {
label="InMemoryTableScan";
3912 [labelType="html" label="MapPartitionsRDD [3912]<br>foreachPartition at SparkFunctionUtil.java:146"];
3913 [labelType="html" label="MapPartitionsRDD [3913]<br>foreachPartition at SparkFunctionUtil.java:146"];
3914 [labelType="html" label="MapPartitionsRDD [3914]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster9435 {
label="WholeStageCodegen (1)";
3915 [labelType="html" label="MapPartitionsRDD [3915]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster9434 {
label="DeserializeToObject";
3916 [labelType="html" label="MapPartitionsRDD [3916]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster9439 {
label="mapPartitions";
3918 [labelType="html" label="MapPartitionsRDD [3918]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
}
3855->3856;
3856->3857;
3857->3858;
3858->3859;
3859->3860;
3860->3912;
3912->3913;
3913->3914;
3914->3915;
3915->3916;
3916->3917;
3917->3918;
}
3860