digraph G {
subgraph clusterstage_188 {
label="Stage 188";
684 [labelType="html" label="JDBCRDD [684]<br>cache at ValueReplaceNode.java:62"];
746 [labelType="html" label="SQLExecutionRDD [746]<br>foreachPartition at SparkFunctionUtil.java:146"];
subgraph cluster1672 {
label="WholeStageCodegen (1)";
685 [labelType="html" label="MapPartitionsRDD [685]<br>count at DatasetOutput.java:65"];
}
subgraph cluster1671 {
label="Generate";
686 [labelType="html" label="MapPartitionsRDD [686]<br>count at DatasetOutput.java:65"];
}
subgraph cluster1666 {
label="WholeStageCodegen (2)";
687 [labelType="html" label="MapPartitionsRDD [687]<br>count at DatasetOutput.java:65"];
}
subgraph cluster1665 {
label="InMemoryTableScan";
688 [labelType="html" label="MapPartitionsRDD [688]<br>count at DatasetOutput.java:65"];
689 [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#6678, 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#6679, 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#6680, if (assertnotnull(input[0, org.apache.spark.... [689] [Cached]<br>count at DatasetOutput.java:65"];
}
subgraph cluster1794 {
label="InMemoryTableScan";
741 [labelType="html" label="MapPartitionsRDD [741]<br>foreachPartition at SparkFunctionUtil.java:146"];
742 [labelType="html" label="MapPartitionsRDD [742]<br>foreachPartition at SparkFunctionUtil.java:146"];
743 [labelType="html" label="MapPartitionsRDD [743]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster1791 {
label="WholeStageCodegen (1)";
744 [labelType="html" label="MapPartitionsRDD [744]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster1790 {
label="DeserializeToObject";
745 [labelType="html" label="MapPartitionsRDD [745]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster1795 {
label="mapPartitions";
747 [labelType="html" label="MapPartitionsRDD [747]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
}
684->685;
685->686;
686->687;
687->688;
688->689;
689->741;
741->742;
742->743;
743->744;
744->745;
745->746;
746->747;
}
689