PlusAMP App Middleware - Details for Query 226805

Submitted Time: 2025/08/01 15:59:21
Duration: 0.2 s
Succeeded Jobs: 330528

Show the Stage ID and Task ID that corresponds to the max metric

digraph G { 0 [labelType="html" label=" CollectLimit "]; 1 [labelType="html" label=" InMemoryTableScan "]; subgraph cluster2 { isCluster="true"; label="WholeStageCodegen (2)"; 3 [labelType="html" label=" Sort "]; } 4 [labelType="html" label="Exchange number of partitions: 200"]; subgraph cluster5 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: 1 ms"; 6 [labelType="html" label=" Project "]; } 7 [labelType="html" label="InMemoryTableScan number of output rows: 4,850"]; subgraph cluster8 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: 240 ms"; 9 [labelType="html" label=" Project "]; } 10 [labelType="html" label="Scan csv number of output rows: 4,850 number of files read: 1 metadata time: 0 ms size of files read: 1830.6 KiB"]; 1->0; 3->1; 4->3; 6->4; 7->6; 9->7; 10->9; }

CollectLimit 1000000

InMemoryTableScan [date#94121010, cum_gross#94121249, cum_net#94121250]

Sort [date#94121010 ASC NULLS FIRST], true, 0

WholeStageCodegen (2)

Exchange rangepartitioning(date#94121010 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7514805]

Project [date#94121010, allcum#94121015 AS cum_gross#94121249, allcumnet#94121019 AS cum_net#94121250]

WholeStageCodegen (1)

InMemoryTableScan [allcum#94121015, allcumnet#94121019, date#94121010]

Project [CASE WHEN (date#94119419 = null) THEN null ELSE cast(date#94119419 as date) END AS date#94119517, CASE WHEN ((allret#94119420 = NA) OR (allret#94119420 = null)) THEN null ELSE cast(allret#94119420 as float) END AS allret#94119518, CASE WHEN ((allcum#94119421 = NA) OR (allcum#94119421 = null)) THEN null ELSE cast(allcum#94119421 as float) END AS allcum#94119519, CASE WHEN ((drawdown_gross#94119422 = NA) OR (drawdown_gross#94119422 = null)) THEN null ELSE cast(drawdown_gross#94119422 as float) END AS drawdown_gross#94119520, CASE WHEN ((drawdown_length_gross#94119423 = NA) OR (drawdown_length_gross#94119423 = null)) THEN null ELSE cast(drawdown_length_gross#94119423 as int) END AS drawdown_length_gross#94119521, CASE WHEN ((allretnet#94119424 = NA) OR (allretnet#94119424 = null)) THEN null ELSE cast(allretnet#94119424 as float) END AS allretnet#94119522, CASE WHEN ((allcumnet#94119425 = NA) OR (allcumnet#94119425 = null)) THEN null ELSE cast(allcumnet#94119425 as float) END AS allcumnet#94119523, CASE WHEN ((drawdown_net#94119426 = NA) OR (drawdown_net#94119426 = null)) THEN null ELSE cast(drawdown_net#94119426 as float) END AS drawdown_net#94119524, CASE WHEN ((drawdown_length_net#94119427 = NA) OR (drawdown_length_net#94119427 = null)) THEN null ELSE cast(drawdown_length_net#94119427 as int) END AS drawdown_length_net#94119525, CASE WHEN ((numcos#94119428 = NA) OR (numcos#94119428 = null)) THEN null ELSE cast(numcos#94119428 as float) END AS numcos#94119527, CASE WHEN ((largecum#94119429 = NA) OR (largecum#94119429 = null)) THEN null ELSE cast(largecum#94119429 as float) END AS largecum#94119529, CASE WHEN ((largecumnet#94119430 = NA) OR (largecumnet#94119430 = null)) THEN null ELSE cast(largecumnet#94119430 as float) END AS largecumnet#94119555, CASE WHEN ((largeret#94119431 = NA) OR (largeret#94119431 = null)) THEN null ELSE cast(largeret#94119431 as float) END AS largeret#94119556, CASE WHEN ((largeretnet#94119432 = NA) OR (largeretnet#94119432 = null)) THEN null ELSE cast(largeretnet#94119432 as float) END AS largeretnet#94119557, CASE WHEN ((midcum#94119433 = NA) OR (midcum#94119433 = null)) THEN null ELSE cast(midcum#94119433 as float) END AS midcum#94119558, CASE WHEN ((midcumnet#94119434 = NA) OR (midcumnet#94119434 = null)) THEN null ELSE cast(midcumnet#94119434 as float) END AS midcumnet#94119559, CASE WHEN ((midret#94119435 = NA) OR (midret#94119435 = null)) THEN null ELSE cast(midret#94119435 as float) END AS midret#94119565, CASE WHEN ((midretnet#94119436 = NA) OR (midretnet#94119436 = null)) THEN null ELSE cast(midretnet#94119436 as float) END AS midretnet#94119570, CASE WHEN ((smallcum#94119437 = NA) OR (smallcum#94119437 = null)) THEN null ELSE cast(smallcum#94119437 as float) END AS smallcum#94119572, CASE WHEN ((smallcumnet#94119438 = NA) OR (smallcumnet#94119438 = null)) THEN null ELSE cast(smallcumnet#94119438 as float) END AS smallcumnet#94119578, CASE WHEN ((smallret#94119439 = NA) OR (smallret#94119439 = null)) THEN null ELSE cast(smallret#94119439 as float) END AS smallret#94119579, CASE WHEN ((smallretnet#94119440 = NA) OR (smallretnet#94119440 = null)) THEN null ELSE cast(smallretnet#94119440 as float) END AS smallretnet#94119585]

WholeStageCodegen (1)

FileScan csv [date#94119419,allret#94119420,allcum#94119421,drawdown_gross#94119422,drawdown_length_gross#94119423,allretnet#94119424,allcumnet#94119425,drawdown_net#94119426,drawdown_length_net#94119427,numcos#94119428,largecum#94119429,largecumnet#94119430,largeret#94119431,largeretnet#94119432,midcum#94119433,midcumnet#94119434,midret#94119435,midretnet#94119436,smallcum#94119437,smallcumnet#94119438,smallret#94119439,smallretnet#94119440] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/output/transcripts/transcript..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<date:string,allret:string,allcum:string,drawdown_gross:string,drawdown_length_gross:string...

Details

== Physical Plan ==
CollectLimit (10)
+- InMemoryTableScan (1)
      +- InMemoryRelation (2)
            +- * Sort (9)
               +- Exchange (8)
                  +- * Project (7)
                     +- InMemoryTableScan (3)
                           +- InMemoryRelation (4)
                                 +- * Project (6)
                                    +- Scan csv  (5)


(1) InMemoryTableScan
Output [3]: [date#94121010, cum_gross#94121249, cum_net#94121250]
Arguments: [date#94121010, cum_gross#94121249, cum_net#94121250]

(2) InMemoryRelation
Arguments: [date#94121010, cum_gross#94121249, cum_net#94121250], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@208e3fd9,StorageLevel(disk, memory, deserialized, 1 replicas),*(2) Sort [date#94121010 ASC NULLS FIRST], true, 0
+- Exchange rangepartitioning(date#94121010 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7514805]
   +- *(1) Project [date#94121010, allcum#94121015 AS cum_gross#94121249, allcumnet#94121019 AS cum_net#94121250]
      +- InMemoryTableScan [allcum#94121015, allcumnet#94121019, date#94121010]
            +- InMemoryRelation [date#94121010, allret#94121013, allcum#94121015, drawdown_gross#94121016, drawdown_length_gross#94121017, allretnet#94121018, allcumnet#94121019, drawdown_net#94121020, drawdown_length_net#94121021, numcos#94121022, largecum#94121133, largecumnet#94121134, largeret#94121135, largeretnet#94121136, midcum#94121137, midcumnet#94121138, midret#94121139, midretnet#94121140, smallcum#94121141, smallcumnet#94121142, smallret#94121143, smallretnet#94121144], StorageLevel(disk, memory, deserialized, 1 replicas)
                  +- *(1) Project [CASE WHEN (date#94119419 = null) THEN null ELSE cast(date#94119419 as date) END AS date#94119517, CASE WHEN ((allret#94119420 = NA) OR (allret#94119420 = null)) THEN null ELSE cast(allret#94119420 as float) END AS allret#94119518, CASE WHEN ((allcum#94119421 = NA) OR (allcum#94119421 = null)) THEN null ELSE cast(allcum#94119421 as float) END AS allcum#94119519, CASE WHEN ((drawdown_gross#94119422 = NA) OR (drawdown_gross#94119422 = null)) THEN null ELSE cast(drawdown_gross#94119422 as float) END AS drawdown_gross#94119520, CASE WHEN ((drawdown_length_gross#94119423 = NA) OR (drawdown_length_gross#94119423 = null)) THEN null ELSE cast(drawdown_length_gross#94119423 as int) END AS drawdown_length_gross#94119521, CASE WHEN ((allretnet#94119424 = NA) OR (allretnet#94119424 = null)) THEN null ELSE cast(allretnet#94119424 as float) END AS allretnet#94119522, CASE WHEN ((allcumnet#94119425 = NA) OR (allcumnet#94119425 = null)) THEN null ELSE cast(allcumnet#94119425 as float) END AS allcumnet#94119523, CASE WHEN ((drawdown_net#94119426 = NA) OR (drawdown_net#94119426 = null)) THEN null ELSE cast(drawdown_net#94119426 as float) END AS drawdown_net#94119524, CASE WHEN ((drawdown_length_net#94119427 = NA) OR (drawdown_length_net#94119427 = null)) THEN null ELSE cast(drawdown_length_net#94119427 as int) END AS drawdown_length_net#94119525, CASE WHEN ((numcos#94119428 = NA) OR (numcos#94119428 = null)) THEN null ELSE cast(numcos#94119428 as float) END AS numcos#94119527, CASE WHEN ((largecum#94119429 = NA) OR (largecum#94119429 = null)) THEN null ELSE cast(largecum#94119429 as float) END AS largecum#94119529, CASE WHEN ((largecumnet#94119430 = NA) OR (largecumnet#94119430 = null)) THEN null ELSE cast(largecumnet#94119430 as float) END AS largecumnet#94119555, CASE WHEN ((largeret#94119431 = NA) OR (largeret#94119431 = null)) THEN null ELSE cast(largeret#94119431 as float) END AS largeret#94119556, CASE WHEN ((largeretnet#94119432 = NA) OR (largeretnet#94119432 = null)) THEN null ELSE cast(largeretnet#94119432 as float) END AS largeretnet#94119557, CASE WHEN ((midcum#94119433 = NA) OR (midcum#94119433 = null)) THEN null ELSE cast(midcum#94119433 as float) END AS midcum#94119558, CASE WHEN ((midcumnet#94119434 = NA) OR (midcumnet#94119434 = null)) THEN null ELSE cast(midcumnet#94119434 as float) END AS midcumnet#94119559, CASE WHEN ((midret#94119435 = NA) OR (midret#94119435 = null)) THEN null ELSE cast(midret#94119435 as float) END AS midret#94119565, CASE WHEN ((midretnet#94119436 = NA) OR (midretnet#94119436 = null)) THEN null ELSE cast(midretnet#94119436 as float) END AS midretnet#94119570, CASE WHEN ((smallcum#94119437 = NA) OR (smallcum#94119437 = null)) THEN null ELSE cast(smallcum#94119437 as float) END AS smallcum#94119572, CASE WHEN ((smallcumnet#94119438 = NA) OR (smallcumnet#94119438 = null)) THEN null ELSE cast(smallcumnet#94119438 as float) END AS smallcumnet#94119578, CASE WHEN ((smallret#94119439 = NA) OR (smallret#94119439 = null)) THEN null ELSE cast(smallret#94119439 as float) END AS smallret#94119579, CASE WHEN ((smallretnet#94119440 = NA) OR (smallretnet#94119440 = null)) THEN null ELSE cast(smallretnet#94119440 as float) END AS smallretnet#94119585]
                     +- FileScan csv [date#94119419,allret#94119420,allcum#94119421,drawdown_gross#94119422,drawdown_length_gross#94119423,allretnet#94119424,allcumnet#94119425,drawdown_net#94119426,drawdown_length_net#94119427,numcos#94119428,largecum#94119429,largecumnet#94119430,largeret#94119431,largeretnet#94119432,midcum#94119433,midcumnet#94119434,midret#94119435,midretnet#94119436,smallcum#94119437,smallcumnet#94119438,smallret#94119439,smallretnet#94119440] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/output/transcripts/transcript..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<date:string,allret:string,allcum:string,drawdown_gross:string,drawdown_length_gross:string...
,None), [date#94121010 ASC NULLS FIRST]

(3) InMemoryTableScan
Output [3]: [allcum#94121015, allcumnet#94121019, date#94121010]
Arguments: [allcum#94121015, allcumnet#94121019, date#94121010]

(4) InMemoryRelation
Arguments: [date#94121010, allret#94121013, allcum#94121015, drawdown_gross#94121016, drawdown_length_gross#94121017, allretnet#94121018, allcumnet#94121019, drawdown_net#94121020, drawdown_length_net#94121021, numcos#94121022, largecum#94121133, largecumnet#94121134, largeret#94121135, largeretnet#94121136, midcum#94121137, midcumnet#94121138, midret#94121139, midretnet#94121140, smallcum#94121141, smallcumnet#94121142, smallret#94121143, smallretnet#94121144], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@208e3fd9,StorageLevel(disk, memory, deserialized, 1 replicas),*(1) Project [CASE WHEN (date#94119419 = null) THEN null ELSE cast(date#94119419 as date) END AS date#94119517, CASE WHEN ((allret#94119420 = NA) OR (allret#94119420 = null)) THEN null ELSE cast(allret#94119420 as float) END AS allret#94119518, CASE WHEN ((allcum#94119421 = NA) OR (allcum#94119421 = null)) THEN null ELSE cast(allcum#94119421 as float) END AS allcum#94119519, CASE WHEN ((drawdown_gross#94119422 = NA) OR (drawdown_gross#94119422 = null)) THEN null ELSE cast(drawdown_gross#94119422 as float) END AS drawdown_gross#94119520, CASE WHEN ((drawdown_length_gross#94119423 = NA) OR (drawdown_length_gross#94119423 = null)) THEN null ELSE cast(drawdown_length_gross#94119423 as int) END AS drawdown_length_gross#94119521, CASE WHEN ((allretnet#94119424 = NA) OR (allretnet#94119424 = null)) THEN null ELSE cast(allretnet#94119424 as float) END AS allretnet#94119522, CASE WHEN ((allcumnet#94119425 = NA) OR (allcumnet#94119425 = null)) THEN null ELSE cast(allcumnet#94119425 as float) END AS allcumnet#94119523, CASE WHEN ((drawdown_net#94119426 = NA) OR (drawdown_net#94119426 = null)) THEN null ELSE cast(drawdown_net#94119426 as float) END AS drawdown_net#94119524, CASE WHEN ((drawdown_length_net#94119427 = NA) OR (drawdown_length_net#94119427 = null)) THEN null ELSE cast(drawdown_length_net#94119427 as int) END AS drawdown_length_net#94119525, CASE WHEN ((numcos#94119428 = NA) OR (numcos#94119428 = null)) THEN null ELSE cast(numcos#94119428 as float) END AS numcos#94119527, CASE WHEN ((largecum#94119429 = NA) OR (largecum#94119429 = null)) THEN null ELSE cast(largecum#94119429 as float) END AS largecum#94119529, CASE WHEN ((largecumnet#94119430 = NA) OR (largecumnet#94119430 = null)) THEN null ELSE cast(largecumnet#94119430 as float) END AS largecumnet#94119555, CASE WHEN ((largeret#94119431 = NA) OR (largeret#94119431 = null)) THEN null ELSE cast(largeret#94119431 as float) END AS largeret#94119556, CASE WHEN ((largeretnet#94119432 = NA) OR (largeretnet#94119432 = null)) THEN null ELSE cast(largeretnet#94119432 as float) END AS largeretnet#94119557, CASE WHEN ((midcum#94119433 = NA) OR (midcum#94119433 = null)) THEN null ELSE cast(midcum#94119433 as float) END AS midcum#94119558, CASE WHEN ((midcumnet#94119434 = NA) OR (midcumnet#94119434 = null)) THEN null ELSE cast(midcumnet#94119434 as float) END AS midcumnet#94119559, CASE WHEN ((midret#94119435 = NA) OR (midret#94119435 = null)) THEN null ELSE cast(midret#94119435 as float) END AS midret#94119565, CASE WHEN ((midretnet#94119436 = NA) OR (midretnet#94119436 = null)) THEN null ELSE cast(midretnet#94119436 as float) END AS midretnet#94119570, CASE WHEN ((smallcum#94119437 = NA) OR (smallcum#94119437 = null)) THEN null ELSE cast(smallcum#94119437 as float) END AS smallcum#94119572, CASE WHEN ((smallcumnet#94119438 = NA) OR (smallcumnet#94119438 = null)) THEN null ELSE cast(smallcumnet#94119438 as float) END AS smallcumnet#94119578, CASE WHEN ((smallret#94119439 = NA) OR (smallret#94119439 = null)) THEN null ELSE cast(smallret#94119439 as float) END AS smallret#94119579, CASE WHEN ((smallretnet#94119440 = NA) OR (smallretnet#94119440 = null)) THEN null ELSE cast(smallretnet#94119440 as float) END AS smallretnet#94119585]
+- FileScan csv [date#94119419,allret#94119420,allcum#94119421,drawdown_gross#94119422,drawdown_length_gross#94119423,allretnet#94119424,allcumnet#94119425,drawdown_net#94119426,drawdown_length_net#94119427,numcos#94119428,largecum#94119429,largecumnet#94119430,largeret#94119431,largeretnet#94119432,midcum#94119433,midcumnet#94119434,midret#94119435,midretnet#94119436,smallcum#94119437,smallcumnet#94119438,smallret#94119439,smallretnet#94119440] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/output/transcripts/transcript..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<date:string,allret:string,allcum:string,drawdown_gross:string,drawdown_length_gross:string...
,None)

(5) Scan csv 
Output [22]: [date#94119419, allret#94119420, allcum#94119421, drawdown_gross#94119422, drawdown_length_gross#94119423, allretnet#94119424, allcumnet#94119425, drawdown_net#94119426, drawdown_length_net#94119427, numcos#94119428, largecum#94119429, largecumnet#94119430, largeret#94119431, largeretnet#94119432, midcum#94119433, midcumnet#94119434, midret#94119435, midretnet#94119436, smallcum#94119437, smallcumnet#94119438, smallret#94119439, smallretnet#94119440]
Batched: false
Location: InMemoryFileIndex [file:/srv/plusamp/data/default/ea-market/output/transcripts/transcript_model_residualized/REPORT_cumret.csv]
ReadSchema: struct<date:string,allret:string,allcum:string,drawdown_gross:string,drawdown_length_gross:string,allretnet:string,allcumnet:string,drawdown_net:string,drawdown_length_net:string,numcos:string,largecum:string,largecumnet:string,largeret:string,largeretnet:string,midcum:string,midcumnet:string,midret:string,midretnet:string,smallcum:string,smallcumnet:string,smallret:string,smallretnet:string>

(6) Project [codegen id : 1]
Output [22]: [CASE WHEN (date#94119419 = null) THEN null ELSE cast(date#94119419 as date) END AS date#94119517, CASE WHEN ((allret#94119420 = NA) OR (allret#94119420 = null)) THEN null ELSE cast(allret#94119420 as float) END AS allret#94119518, CASE WHEN ((allcum#94119421 = NA) OR (allcum#94119421 = null)) THEN null ELSE cast(allcum#94119421 as float) END AS allcum#94119519, CASE WHEN ((drawdown_gross#94119422 = NA) OR (drawdown_gross#94119422 = null)) THEN null ELSE cast(drawdown_gross#94119422 as float) END AS drawdown_gross#94119520, CASE WHEN ((drawdown_length_gross#94119423 = NA) OR (drawdown_length_gross#94119423 = null)) THEN null ELSE cast(drawdown_length_gross#94119423 as int) END AS drawdown_length_gross#94119521, CASE WHEN ((allretnet#94119424 = NA) OR (allretnet#94119424 = null)) THEN null ELSE cast(allretnet#94119424 as float) END AS allretnet#94119522, CASE WHEN ((allcumnet#94119425 = NA) OR (allcumnet#94119425 = null)) THEN null ELSE cast(allcumnet#94119425 as float) END AS allcumnet#94119523, CASE WHEN ((drawdown_net#94119426 = NA) OR (drawdown_net#94119426 = null)) THEN null ELSE cast(drawdown_net#94119426 as float) END AS drawdown_net#94119524, CASE WHEN ((drawdown_length_net#94119427 = NA) OR (drawdown_length_net#94119427 = null)) THEN null ELSE cast(drawdown_length_net#94119427 as int) END AS drawdown_length_net#94119525, CASE WHEN ((numcos#94119428 = NA) OR (numcos#94119428 = null)) THEN null ELSE cast(numcos#94119428 as float) END AS numcos#94119527, CASE WHEN ((largecum#94119429 = NA) OR (largecum#94119429 = null)) THEN null ELSE cast(largecum#94119429 as float) END AS largecum#94119529, CASE WHEN ((largecumnet#94119430 = NA) OR (largecumnet#94119430 = null)) THEN null ELSE cast(largecumnet#94119430 as float) END AS largecumnet#94119555, CASE WHEN ((largeret#94119431 = NA) OR (largeret#94119431 = null)) THEN null ELSE cast(largeret#94119431 as float) END AS largeret#94119556, CASE WHEN ((largeretnet#94119432 = NA) OR (largeretnet#94119432 = null)) THEN null ELSE cast(largeretnet#94119432 as float) END AS largeretnet#94119557, CASE WHEN ((midcum#94119433 = NA) OR (midcum#94119433 = null)) THEN null ELSE cast(midcum#94119433 as float) END AS midcum#94119558, CASE WHEN ((midcumnet#94119434 = NA) OR (midcumnet#94119434 = null)) THEN null ELSE cast(midcumnet#94119434 as float) END AS midcumnet#94119559, CASE WHEN ((midret#94119435 = NA) OR (midret#94119435 = null)) THEN null ELSE cast(midret#94119435 as float) END AS midret#94119565, CASE WHEN ((midretnet#94119436 = NA) OR (midretnet#94119436 = null)) THEN null ELSE cast(midretnet#94119436 as float) END AS midretnet#94119570, CASE WHEN ((smallcum#94119437 = NA) OR (smallcum#94119437 = null)) THEN null ELSE cast(smallcum#94119437 as float) END AS smallcum#94119572, CASE WHEN ((smallcumnet#94119438 = NA) OR (smallcumnet#94119438 = null)) THEN null ELSE cast(smallcumnet#94119438 as float) END AS smallcumnet#94119578, CASE WHEN ((smallret#94119439 = NA) OR (smallret#94119439 = null)) THEN null ELSE cast(smallret#94119439 as float) END AS smallret#94119579, CASE WHEN ((smallretnet#94119440 = NA) OR (smallretnet#94119440 = null)) THEN null ELSE cast(smallretnet#94119440 as float) END AS smallretnet#94119585]
Input [22]: [date#94119419, allret#94119420, allcum#94119421, drawdown_gross#94119422, drawdown_length_gross#94119423, allretnet#94119424, allcumnet#94119425, drawdown_net#94119426, drawdown_length_net#94119427, numcos#94119428, largecum#94119429, largecumnet#94119430, largeret#94119431, largeretnet#94119432, midcum#94119433, midcumnet#94119434, midret#94119435, midretnet#94119436, smallcum#94119437, smallcumnet#94119438, smallret#94119439, smallretnet#94119440]

(7) Project [codegen id : 1]
Output [3]: [date#94121010, allcum#94121015 AS cum_gross#94121249, allcumnet#94121019 AS cum_net#94121250]
Input [3]: [allcum#94121015, allcumnet#94121019, date#94121010]

(8) Exchange
Input [3]: [date#94121010, cum_gross#94121249, cum_net#94121250]
Arguments: rangepartitioning(date#94121010 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7514805]

(9) Sort [codegen id : 2]
Input [3]: [date#94121010, cum_gross#94121249, cum_net#94121250]
Arguments: [date#94121010 ASC NULLS FIRST], true, 0

(10) CollectLimit
Input [3]: [date#94121010, cum_gross#94121249, cum_net#94121250]
Arguments: 1000000