digraph G {
subgraph clusterstage_786 {
label="Stage 786";
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 cluster7517 {
label="InMemoryTableScan";
3114 [labelType="html" label="MapPartitionsRDD [3114]<br>collectAsList at DataStorageUtils.java:104"];
3115 [labelType="html" label="MapPartitionsRDD [3115]<br>collectAsList at DataStorageUtils.java:104"];
3116 [labelType="html" label="MapPartitionsRDD [3116]<br>collectAsList at DataStorageUtils.java:104"];
}
subgraph cluster7518 {
label="mapPartitionsInternal";
3117 [labelType="html" label="MapPartitionsRDD [3117]<br>collectAsList at DataStorageUtils.java:104"];
}
}
3100->3101;
3101->3102;
3102->3103;
3103->3104;
3104->3105;
3105->3114;
3114->3115;
3115->3116;
3116->3117;
}
3105