digraph G {
subgraph clusterstage_795 {
label="Stage 795";
3100 [labelType="html" label="JDBCRDD [3100]<br>cache at ValueReplaceNode.java:62"];
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 cluster7606 {
label="InMemoryTableScan";
3152 [labelType="html" label="MapPartitionsRDD [3152]<br>collectAsList at DataStorageUtils.java:104"];
3153 [labelType="html" label="MapPartitionsRDD [3153]<br>collectAsList at DataStorageUtils.java:104"];
3154 [labelType="html" label="MapPartitionsRDD [3154]<br>collectAsList at DataStorageUtils.java:104"];
}
subgraph cluster7603 {
label="WholeStageCodegen (1)";
3155 [labelType="html" label="MapPartitionsRDD [3155]<br>collectAsList at DataStorageUtils.java:104"];
}
subgraph cluster7607 {
label="mapPartitionsInternal";
3156 [labelType="html" label="MapPartitionsRDD [3156]<br>collectAsList at DataStorageUtils.java:104"];
}
}
3100->3101;
3101->3102;
3102->3103;
3103->3104;
3104->3105;
3105->3152;
3152->3153;
3153->3154;
3154->3155;
3155->3156;
}
3105