digraph G {
subgraph clusterstage_713 {
label="Stage 713";
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 cluster6818 {
label="InMemoryTableScan";
2824 [labelType="html" label="MapPartitionsRDD [2824]<br>collectAsList at DataStorageUtils.java:104"];
2825 [labelType="html" label="MapPartitionsRDD [2825]<br>collectAsList at DataStorageUtils.java:104"];
2826 [labelType="html" label="MapPartitionsRDD [2826]<br>collectAsList at DataStorageUtils.java:104"];
}
subgraph cluster6815 {
label="WholeStageCodegen (1)";
2827 [labelType="html" label="MapPartitionsRDD [2827]<br>collectAsList at DataStorageUtils.java:104"];
}
subgraph cluster6819 {
label="mapPartitionsInternal";
2828 [labelType="html" label="MapPartitionsRDD [2828]<br>collectAsList at DataStorageUtils.java:104"];
}
}
2798->2799;
2799->2800;
2800->2801;
2801->2802;
2802->2803;
2803->2824;
2824->2825;
2825->2826;
2826->2827;
2827->2828;
}
2803