PlusAMP App Middleware - Details for Stage 513130 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 8 ms
Locality Level Summary: Node local: 1; Process local: 1
Shuffle Read Size / Records: 134.0 B / 3
Shuffle Write Size / Records: 154.0 B / 3
Associated Job Ids: 331511

digraph G { subgraph clusterstage_513130 { label="Stage 513130"; subgraph cluster6304106 { label="Exchange"; 3625358 [labelType="html" label="ShuffledRowRDD [3625358] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6304102 { label="WholeStageCodegen (3)"; 3625359 [labelType="html" label="MapPartitionsRDD [3625359] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6304101 { label="InMemoryTableScan"; 3625360 [labelType="html" label="MapPartitionsRDD [3625360] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3625361 [labelType="html" label="*(3) Project [cap#94399081, turnover#94396615, (1.0 / cast(turnover#94396615 as double)) AS days_hold#94399110]\n+- *(3) Sort [cap_sort#94399020 ASC NULLS FIRST], true, 0\n +- Exchange rangepartitioning(cap_sort#94399020 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7537098]\n +- *(2) Project [turnover#94396615, cap_description#94399019 AS cap#94399081, cap_sort#94399020]\n +- *(2) BroadcastHashJoin [knownfloatingpointnormalized(normalizenanandzero(cap#94396456))], [knownfloatingpointnormalized(normalizenanandzero(cast(cap#94160394 as float)))], Inner, BuildLeft, false\n :- BroadcastExchange HashedRelationBroadcastMode(List(knownfloatingpointnormalized(normalizenanandzero(input[0, float, false]))),false), [id=#7537090]\n : +- *(1) Filter isnotnull(cap#94396456)\n : +- *(1) ColumnarToRow\n : +- InMemoryTableScan [cap#94396456, turnover#94396615], [isnotnull(cap#94396456)]\n : +- InMemoryRelation [cap#94396456, retIC#943... [3625361] [Cached] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3625362 [labelType="html" label="MapPartitionsRDD [3625362] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3625363 [labelType="html" label="MapPartitionsRDD [3625363] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3625364 [labelType="html" label="MapPartitionsRDD [3625364] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6304100 { label="CollectLimit"; 3625365 [labelType="html" label="MapPartitionsRDD [3625365] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3625366 [labelType="html" label="MapPartitionsRDD [3625366] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } } 3625358->3625359; 3625359->3625360; 3625360->3625361; 3625361->3625362; 3625362->3625363; 3625363->3625364; 3625364->3625365; 3625365->3625366; }

3625357,3625358

3625361

Event Timeline

Enable zooming