digraph G {
subgraph clusterstage_1062 {
label="Stage 1062";
4157 [labelType="html" label="JDBCRDD [4157]<br>cache at ValueReplaceNode.java:62"];
4219 [labelType="html" label="SQLExecutionRDD [4219]<br>foreachPartition at SparkFunctionUtil.java:146"];
subgraph cluster10044 {
label="WholeStageCodegen (1)";
4158 [labelType="html" label="MapPartitionsRDD [4158]<br>count at DatasetOutput.java:65"];
}
subgraph cluster10043 {
label="Generate";
4159 [labelType="html" label="MapPartitionsRDD [4159]<br>count at DatasetOutput.java:65"];
}
subgraph cluster10038 {
label="WholeStageCodegen (2)";
4160 [labelType="html" label="MapPartitionsRDD [4160]<br>count at DatasetOutput.java:65"];
}
subgraph cluster10037 {
label="InMemoryTableScan";
4161 [labelType="html" label="MapPartitionsRDD [4161]<br>count at DatasetOutput.java:65"];
4162 [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#43478, 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#43479, 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#43480, if (assertnotnull(input[0, org.apache.spa... [4162] [Cached]<br>count at DatasetOutput.java:65"];
}
subgraph cluster10166 {
label="InMemoryTableScan";
4214 [labelType="html" label="MapPartitionsRDD [4214]<br>foreachPartition at SparkFunctionUtil.java:146"];
4215 [labelType="html" label="MapPartitionsRDD [4215]<br>foreachPartition at SparkFunctionUtil.java:146"];
4216 [labelType="html" label="MapPartitionsRDD [4216]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster10163 {
label="WholeStageCodegen (1)";
4217 [labelType="html" label="MapPartitionsRDD [4217]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster10162 {
label="DeserializeToObject";
4218 [labelType="html" label="MapPartitionsRDD [4218]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster10167 {
label="mapPartitions";
4220 [labelType="html" label="MapPartitionsRDD [4220]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
}
4157->4158;
4158->4159;
4159->4160;
4160->4161;
4161->4162;
4162->4214;
4214->4215;
4215->4216;
4216->4217;
4217->4218;
4218->4219;
4219->4220;
}
4162