digraph G {
subgraph clusterstage_799 {
label="Stage 799";
3100 [labelType="html" label="JDBCRDD [3100]<br>cache at ValueReplaceNode.java:62"];
subgraph cluster7496 {
label="WholeStageCodegen (1)";
3101 [labelType="html" label="MapPartitionsRDD [3101]<br>count at DatasetOutput.java:65"];
}
subgraph cluster7495 {
label="Generate";
3102 [labelType="html" label="MapPartitionsRDD [3102]<br>count at DatasetOutput.java:65"];
}
subgraph cluster7490 {
label="WholeStageCodegen (2)";
3103 [labelType="html" label="MapPartitionsRDD [3103]<br>count at DatasetOutput.java:65"];
}
subgraph cluster7489 {
label="InMemoryTableScan";
3104 [labelType="html" label="MapPartitionsRDD [3104]<br>count at DatasetOutput.java:65"];
3105 [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#32278, 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#32279, 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#32280, if (assertnotnull(input[0, org.apache.spa... [3105] [Cached]<br>count at DatasetOutput.java:65"];
}
subgraph cluster7651 {
label="InMemoryTableScan";
3172 [labelType="html" label="MapPartitionsRDD [3172]<br>collectAsList at DataStorageUtils.java:104"];
3173 [labelType="html" label="MapPartitionsRDD [3173]<br>collectAsList at DataStorageUtils.java:104"];
3174 [labelType="html" label="MapPartitionsRDD [3174]<br>collectAsList at DataStorageUtils.java:104"];
}
subgraph cluster7648 {
label="WholeStageCodegen (1)";
3175 [labelType="html" label="MapPartitionsRDD [3175]<br>collectAsList at DataStorageUtils.java:104"];
}
subgraph cluster7652 {
label="mapPartitionsInternal";
3176 [labelType="html" label="MapPartitionsRDD [3176]<br>collectAsList at DataStorageUtils.java:104"];
}
}
3100->3101;
3101->3102;
3102->3103;
3103->3104;
3104->3105;
3105->3172;
3172->3173;
3173->3174;
3174->3175;
3175->3176;
}
3105