digraph G {
subgraph clusterstage_682 {
label="Stage 682";
2647 [labelType="html" label="JDBCRDD [2647]<br>cache at ValueReplaceNode.java:62"];
2709 [labelType="html" label="SQLExecutionRDD [2709]<br>foreachPartition at SparkFunctionUtil.java:146"];
subgraph cluster6404 {
label="WholeStageCodegen (1)";
2648 [labelType="html" label="MapPartitionsRDD [2648]<br>count at DatasetOutput.java:65"];
}
subgraph cluster6403 {
label="Generate";
2649 [labelType="html" label="MapPartitionsRDD [2649]<br>count at DatasetOutput.java:65"];
}
subgraph cluster6398 {
label="WholeStageCodegen (2)";
2650 [labelType="html" label="MapPartitionsRDD [2650]<br>count at DatasetOutput.java:65"];
}
subgraph cluster6397 {
label="InMemoryTableScan";
2651 [labelType="html" label="MapPartitionsRDD [2651]<br>count at DatasetOutput.java:65"];
2652 [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#27478, 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#27479, 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#27480, if (assertnotnull(input[0, org.apache.spa... [2652] [Cached]<br>count at DatasetOutput.java:65"];
}
subgraph cluster6526 {
label="InMemoryTableScan";
2704 [labelType="html" label="MapPartitionsRDD [2704]<br>foreachPartition at SparkFunctionUtil.java:146"];
2705 [labelType="html" label="MapPartitionsRDD [2705]<br>foreachPartition at SparkFunctionUtil.java:146"];
2706 [labelType="html" label="MapPartitionsRDD [2706]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster6523 {
label="WholeStageCodegen (1)";
2707 [labelType="html" label="MapPartitionsRDD [2707]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster6522 {
label="DeserializeToObject";
2708 [labelType="html" label="MapPartitionsRDD [2708]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster6527 {
label="mapPartitions";
2710 [labelType="html" label="MapPartitionsRDD [2710]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
}
2647->2648;
2648->2649;
2649->2650;
2650->2651;
2651->2652;
2652->2704;
2704->2705;
2705->2706;
2706->2707;
2707->2708;
2708->2709;
2709->2710;
}
2652