digraph G {
subgraph clusterstage_716 {
label="Stage 716";
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 cluster6848 {
label="InMemoryTableScan";
2837 [labelType="html" label="MapPartitionsRDD [2837]<br>collectAsList at DataStorageUtils.java:104"];
2838 [labelType="html" label="MapPartitionsRDD [2838]<br>collectAsList at DataStorageUtils.java:104"];
2839 [labelType="html" label="MapPartitionsRDD [2839]<br>collectAsList at DataStorageUtils.java:104"];
}
subgraph cluster6845 {
label="WholeStageCodegen (1)";
2840 [labelType="html" label="MapPartitionsRDD [2840]<br>collectAsList at DataStorageUtils.java:104"];
}
subgraph cluster6849 {
label="mapPartitionsInternal";
2841 [labelType="html" label="MapPartitionsRDD [2841]<br>collectAsList at DataStorageUtils.java:104"];
}
}
2798->2799;
2799->2800;
2800->2801;
2801->2802;
2802->2803;
2803->2837;
2837->2838;
2838->2839;
2839->2840;
2840->2841;
}
2803