digraph G {
subgraph clusterstage_723 {
label="Stage 723";
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 cluster6923 {
label="InMemoryTableScan";
2870 [labelType="html" label="MapPartitionsRDD [2870]<br>collectAsList at DataStorageUtils.java:104"];
2871 [labelType="html" label="MapPartitionsRDD [2871]<br>collectAsList at DataStorageUtils.java:104"];
2872 [labelType="html" label="MapPartitionsRDD [2872]<br>collectAsList at DataStorageUtils.java:104"];
}
subgraph cluster6920 {
label="WholeStageCodegen (1)";
2873 [labelType="html" label="MapPartitionsRDD [2873]<br>collectAsList at DataStorageUtils.java:104"];
}
subgraph cluster6924 {
label="mapPartitionsInternal";
2874 [labelType="html" label="MapPartitionsRDD [2874]<br>collectAsList at DataStorageUtils.java:104"];
}
}
2798->2799;
2799->2800;
2800->2801;
2801->2802;
2802->2803;
2803->2870;
2870->2871;
2871->2872;
2872->2873;
2873->2874;
}
2803