digraph G {
subgraph clusterstage_710 {
label="Stage 710";
2798 [labelType="html" label="JDBCRDD [2798]<br>cache at ValueReplaceNode.java:62"];
subgraph cluster6768 {
label="WholeStageCodegen (1)";
2799 [labelType="html" label="MapPartitionsRDD [2799]<br>count at DatasetOutput.java:65"];
}
subgraph cluster6767 {
label="Generate";
2800 [labelType="html" label="MapPartitionsRDD [2800]<br>count at DatasetOutput.java:65"];
}
subgraph cluster6762 {
label="WholeStageCodegen (2)";
2801 [labelType="html" label="MapPartitionsRDD [2801]<br>count at DatasetOutput.java:65"];
}
subgraph cluster6761 {
label="InMemoryTableScan";
2802 [labelType="html" label="MapPartitionsRDD [2802]<br>count at DatasetOutput.java:65"];
2803 [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#29078, 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#29079, 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#29080, if (assertnotnull(input[0, org.apache.spa... [2803] [Cached]<br>count at DatasetOutput.java:65"];
}
subgraph cluster6789 {
label="InMemoryTableScan";
2812 [labelType="html" label="MapPartitionsRDD [2812]<br>collectAsList at DataStorageUtils.java:104"];
2813 [labelType="html" label="MapPartitionsRDD [2813]<br>collectAsList at DataStorageUtils.java:104"];
2814 [labelType="html" label="MapPartitionsRDD [2814]<br>collectAsList at DataStorageUtils.java:104"];
}
subgraph cluster6790 {
label="mapPartitionsInternal";
2815 [labelType="html" label="MapPartitionsRDD [2815]<br>collectAsList at DataStorageUtils.java:104"];
}
}
2798->2799;
2799->2800;
2800->2801;
2801->2802;
2802->2803;
2803->2812;
2812->2813;
2813->2814;
2814->2815;
}
2803