digraph G {
subgraph clusterstage_16 {
label="Stage 16";
64 [label="SQLExecutionRDD [64]\njavaToPython at NativeMethodAccessorImpl.java:0"];
subgraph cluster114 {
label="Exchange";
57 [label="ShuffledRowRDD [57]\njavaToPython at NativeMethodAccessorImpl.java:0"];
}
subgraph cluster113 {
label="InMemoryTableScan";
58 [label="MapPartitionsRDD [58]\njavaToPython at NativeMethodAccessorImpl.java:0"];
59 [label="Exchange SinglePartition, REPARTITION_BY_NUM, [id=#243]\n+- InMemoryTableScan [_ingest_dbid#83, _ingest_error_code#84, _ingest_input_s3uri#85, _ingest_timestamp#86, _intake_operator#87, _is_survey#88, _metafile_dttm#89, _table_count#90L, airplane_type#91, application_name#92, cmip#93, customer_name#94, flightarrival#95, flightdeparture#96, flightenddate#97, flightguid#98, flightnum#99, flightstartdate#100, icao_airline#101, metadata_info#102, multiple#103, offload_filename#104, offload_format_version#105, offload_type#106, ... 7 more fields]\n +- InMemoryRelation [_ingest_dbid#83, _ingest_error_code#84, _ingest_input_s3uri#85, _ingest_timestamp#86, _intake_operator#87, _is_survey#88, _metafile_dttm#89, _table_count#90L, airplane_type#91, application_name#92, cmip#93, customer_name#94, flightarrival#95, flightdeparture#96, flightenddate#97, flightguid#98, flightnum#99, flightstartdate#100, icao_airline#101, metadata_info#102, multiple#103, offload_filename#104, offload_format_version#105, offload_type#10... [59] [Cached]\njavaToPython at NativeMethodAccessorImpl.java:0"];
60 [label="MapPartitionsRDD [60]\njavaToPython at NativeMethodAccessorImpl.java:0"];
61 [label="MapPartitionsRDD [61]\njavaToPython at NativeMethodAccessorImpl.java:0"];
62 [label="MapPartitionsRDD [62]\njavaToPython at NativeMethodAccessorImpl.java:0"];
}
subgraph cluster108 {
label="WholeStageCodegen (1)";
63 [label="MapPartitionsRDD [63]\njavaToPython at NativeMethodAccessorImpl.java:0"];
}
subgraph cluster121 {
label="map";
65 [label="MapPartitionsRDD [65]\njavaToPython at NativeMethodAccessorImpl.java:0"];
}
subgraph cluster122 {
label="mapPartitions";
66 [label="MapPartitionsRDD [66]\njavaToPython at NativeMethodAccessorImpl.java:0"];
}
}
57->58;
58->59;
59->60;
60->61;
61->62;
62->63;
63->64;
64->65;
65->66;
}
56,57
59
