digraph G {
subgraph clusterstage_796 {
label="Stage 796";
3100 [labelType="html" label="JDBCRDD [3100]<br>cache at ValueReplaceNode.java:62"];
3162 [labelType="html" label="SQLExecutionRDD [3162]<br>foreachPartition at SparkFunctionUtil.java:146"];
subgraph cluster7496 {
label="WholeStageCodegen (1)";
3101 [labelType="html" label="MapPartitionsRDD [3101]<br>count at DatasetOutput.java:65"];
}
subgraph cluster7495 {
label="Generate";
3102 [labelType="html" label="MapPartitionsRDD [3102]<br>count at DatasetOutput.java:65"];
}
subgraph cluster7490 {
label="WholeStageCodegen (2)";
3103 [labelType="html" label="MapPartitionsRDD [3103]<br>count at DatasetOutput.java:65"];
}
subgraph cluster7489 {
label="InMemoryTableScan";
3104 [labelType="html" label="MapPartitionsRDD [3104]<br>count at DatasetOutput.java:65"];
3105 [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#32278, 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#32279, 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#32280, if (assertnotnull(input[0, org.apache.spa... [3105] [Cached]<br>count at DatasetOutput.java:65"];
}
subgraph cluster7618 {
label="InMemoryTableScan";
3157 [labelType="html" label="MapPartitionsRDD [3157]<br>foreachPartition at SparkFunctionUtil.java:146"];
3158 [labelType="html" label="MapPartitionsRDD [3158]<br>foreachPartition at SparkFunctionUtil.java:146"];
3159 [labelType="html" label="MapPartitionsRDD [3159]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster7615 {
label="WholeStageCodegen (1)";
3160 [labelType="html" label="MapPartitionsRDD [3160]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster7614 {
label="DeserializeToObject";
3161 [labelType="html" label="MapPartitionsRDD [3161]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
subgraph cluster7619 {
label="mapPartitions";
3163 [labelType="html" label="MapPartitionsRDD [3163]<br>foreachPartition at SparkFunctionUtil.java:146"];
}
}
3100->3101;
3101->3102;
3102->3103;
3103->3104;
3104->3105;
3105->3157;
3157->3158;
3158->3159;
3159->3160;
3160->3161;
3161->3162;
3162->3163;
}
3105