digraph G {
subgraph clusterstage_719 {
label="Stage 719";
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 cluster6878 {
label="InMemoryTableScan";
2850 [labelType="html" label="MapPartitionsRDD [2850]<br>collectAsList at DataStorageUtils.java:104"];
2851 [labelType="html" label="MapPartitionsRDD [2851]<br>collectAsList at DataStorageUtils.java:104"];
2852 [labelType="html" label="MapPartitionsRDD [2852]<br>collectAsList at DataStorageUtils.java:104"];
}
subgraph cluster6875 {
label="WholeStageCodegen (1)";
2853 [labelType="html" label="MapPartitionsRDD [2853]<br>collectAsList at DataStorageUtils.java:104"];
}
subgraph cluster6879 {
label="mapPartitionsInternal";
2854 [labelType="html" label="MapPartitionsRDD [2854]<br>collectAsList at DataStorageUtils.java:104"];
}
}
2798->2799;
2799->2800;
2800->2801;
2801->2802;
2802->2803;
2803->2850;
2850->2851;
2851->2852;
2852->2853;
2853->2854;
}
2803