PlusAMP App Middleware - Details for Query 227424

Submitted Time: 2025/08/02 15:23:37
Duration: 76 ms
Succeeded Jobs: 331437

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: 5 ms"; 6 [labelType="html" label=" Project "]; } 7 [labelType="html" label="InMemoryTableScan number of output rows: 6,432"]; subgraph cluster8 { isCluster="true"; label="WholeStageCodegen (1)\n \nduration: 0 ms"; 9 [labelType="html" label=" Project "]; } 10 [labelType="html" label="Scan csv number of output rows: 0"]; 1->0; 3->1; 4->3; 6->4; 7->6; 9->7; 10->9; }

CollectLimit 1000000

InMemoryTableScan [date#94377113, drawdown_length_gross#94377389]

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

WholeStageCodegen (2)

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

Project [date#94377113, (drawdown_length_gross#94377119 * -1) AS drawdown_length_gross#94377389]

WholeStageCodegen (1)

InMemoryTableScan [date#94377113, drawdown_length_gross#94377119]

Project [CASE WHEN (date#94377170 = null) THEN null ELSE cast(date#94377170 as date) END AS date#94377294, CASE WHEN ((allret#94377171 = NA) OR (allret#94377171 = null)) THEN null ELSE cast(allret#94377171 as float) END AS allret#94377300, CASE WHEN ((allcum#94377172 = NA) OR (allcum#94377172 = null)) THEN null ELSE cast(allcum#94377172 as float) END AS allcum#94377301, CASE WHEN ((drawdown_gross#94377173 = NA) OR (drawdown_gross#94377173 = null)) THEN null ELSE cast(drawdown_gross#94377173 as float) END AS drawdown_gross#94377307, CASE WHEN ((drawdown_length_gross#94377174 = NA) OR (drawdown_length_gross#94377174 = null)) THEN null ELSE cast(drawdown_length_gross#94377174 as int) END AS drawdown_length_gross#94377308, CASE WHEN ((allretnet#94377175 = NA) OR (allretnet#94377175 = null)) THEN null ELSE cast(allretnet#94377175 as float) END AS allretnet#94377314, CASE WHEN ((allcumnet#94377176 = NA) OR (allcumnet#94377176 = null)) THEN null ELSE cast(allcumnet#94377176 as float) END AS allcumnet#94377317, CASE WHEN ((drawdown_net#94377177 = NA) OR (drawdown_net#94377177 = null)) THEN null ELSE cast(drawdown_net#94377177 as float) END AS drawdown_net#94377323, CASE WHEN ((drawdown_length_net#94377178 = NA) OR (drawdown_length_net#94377178 = null)) THEN null ELSE cast(drawdown_length_net#94377178 as int) END AS drawdown_length_net#94377324, CASE WHEN ((numcos#94377179 = NA) OR (numcos#94377179 = null)) THEN null ELSE cast(numcos#94377179 as float) END AS numcos#94377325, CASE WHEN ((largecum#94377180 = NA) OR (largecum#94377180 = null)) THEN null ELSE cast(largecum#94377180 as float) END AS largecum#94377326, CASE WHEN ((largecumnet#94377181 = NA) OR (largecumnet#94377181 = null)) THEN null ELSE cast(largecumnet#94377181 as float) END AS largecumnet#94377327, CASE WHEN ((largeret#94377182 = NA) OR (largeret#94377182 = null)) THEN null ELSE cast(largeret#94377182 as float) END AS largeret#94377328, CASE WHEN ((largeretnet#94377183 = NA) OR (largeretnet#94377183 = null)) THEN null ELSE cast(largeretnet#94377183 as float) END AS largeretnet#94377329, CASE WHEN ((midcum#94377184 = NA) OR (midcum#94377184 = null)) THEN null ELSE cast(midcum#94377184 as float) END AS midcum#94377355, CASE WHEN ((midcumnet#94377185 = NA) OR (midcumnet#94377185 = null)) THEN null ELSE cast(midcumnet#94377185 as float) END AS midcumnet#94377356, CASE WHEN ((midret#94377186 = NA) OR (midret#94377186 = null)) THEN null ELSE cast(midret#94377186 as float) END AS midret#94377361, CASE WHEN ((midretnet#94377187 = NA) OR (midretnet#94377187 = null)) THEN null ELSE cast(midretnet#94377187 as float) END AS midretnet#94377362, CASE WHEN ((smallcum#94377188 = NA) OR (smallcum#94377188 = null)) THEN null ELSE cast(smallcum#94377188 as float) END AS smallcum#94377363, CASE WHEN ((smallcumnet#94377189 = NA) OR (smallcumnet#94377189 = null)) THEN null ELSE cast(smallcumnet#94377189 as float) END AS smallcumnet#94377364, CASE WHEN ((smallret#94377190 = NA) OR (smallret#94377190 = null)) THEN null ELSE cast(smallret#94377190 as float) END AS smallret#94377365, CASE WHEN ((smallretnet#94377191 = NA) OR (smallretnet#94377191 = null)) THEN null ELSE cast(smallretnet#94377191 as float) END AS smallretnet#94377366]

WholeStageCodegen (1)

FileScan csv [date#94377170,allret#94377171,allcum#94377172,drawdown_gross#94377173,drawdown_length_gross#94377174,allretnet#94377175,allcumnet#94377176,drawdown_net#94377177,drawdown_length_net#94377178,numcos#94377179,largecum#94377180,largecumnet#94377181,largeret#94377182,largeretnet#94377183,midcum#94377184,midcumnet#94377185,midret#94377186,midretnet#94377187,smallcum#94377188,smallcumnet#94377189,smallret#94377190,smallretnet#94377191] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/output/risk_factors/leverage/..., 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 [2]: [date#94377113, drawdown_length_gross#94377389]
Arguments: [date#94377113, drawdown_length_gross#94377389]

(2) InMemoryRelation
Arguments: [date#94377113, drawdown_length_gross#94377389], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@208e3fd9,StorageLevel(disk, memory, deserialized, 1 replicas),*(2) Sort [date#94377113 ASC NULLS FIRST], true, 0
+- Exchange rangepartitioning(date#94377113 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7535369]
   +- *(1) Project [date#94377113, (drawdown_length_gross#94377119 * -1) AS drawdown_length_gross#94377389]
      +- InMemoryTableScan [date#94377113, drawdown_length_gross#94377119]
            +- InMemoryRelation [date#94377113, allret#94377115, allcum#94377116, drawdown_gross#94377118, drawdown_length_gross#94377119, allretnet#94377120, allcumnet#94377121, drawdown_net#94377163, drawdown_length_net#94377164, numcos#94377167, largecum#94377169, largecumnet#94377192, largeret#94377193, largeretnet#94377219, midcum#94377225, midcumnet#94377253, midret#94377255, midretnet#94377278, smallcum#94377279, smallcumnet#94377281, smallret#94377282, smallretnet#94377283], StorageLevel(disk, memory, deserialized, 1 replicas)
                  +- *(1) Project [CASE WHEN (date#94377170 = null) THEN null ELSE cast(date#94377170 as date) END AS date#94377294, CASE WHEN ((allret#94377171 = NA) OR (allret#94377171 = null)) THEN null ELSE cast(allret#94377171 as float) END AS allret#94377300, CASE WHEN ((allcum#94377172 = NA) OR (allcum#94377172 = null)) THEN null ELSE cast(allcum#94377172 as float) END AS allcum#94377301, CASE WHEN ((drawdown_gross#94377173 = NA) OR (drawdown_gross#94377173 = null)) THEN null ELSE cast(drawdown_gross#94377173 as float) END AS drawdown_gross#94377307, CASE WHEN ((drawdown_length_gross#94377174 = NA) OR (drawdown_length_gross#94377174 = null)) THEN null ELSE cast(drawdown_length_gross#94377174 as int) END AS drawdown_length_gross#94377308, CASE WHEN ((allretnet#94377175 = NA) OR (allretnet#94377175 = null)) THEN null ELSE cast(allretnet#94377175 as float) END AS allretnet#94377314, CASE WHEN ((allcumnet#94377176 = NA) OR (allcumnet#94377176 = null)) THEN null ELSE cast(allcumnet#94377176 as float) END AS allcumnet#94377317, CASE WHEN ((drawdown_net#94377177 = NA) OR (drawdown_net#94377177 = null)) THEN null ELSE cast(drawdown_net#94377177 as float) END AS drawdown_net#94377323, CASE WHEN ((drawdown_length_net#94377178 = NA) OR (drawdown_length_net#94377178 = null)) THEN null ELSE cast(drawdown_length_net#94377178 as int) END AS drawdown_length_net#94377324, CASE WHEN ((numcos#94377179 = NA) OR (numcos#94377179 = null)) THEN null ELSE cast(numcos#94377179 as float) END AS numcos#94377325, CASE WHEN ((largecum#94377180 = NA) OR (largecum#94377180 = null)) THEN null ELSE cast(largecum#94377180 as float) END AS largecum#94377326, CASE WHEN ((largecumnet#94377181 = NA) OR (largecumnet#94377181 = null)) THEN null ELSE cast(largecumnet#94377181 as float) END AS largecumnet#94377327, CASE WHEN ((largeret#94377182 = NA) OR (largeret#94377182 = null)) THEN null ELSE cast(largeret#94377182 as float) END AS largeret#94377328, CASE WHEN ((largeretnet#94377183 = NA) OR (largeretnet#94377183 = null)) THEN null ELSE cast(largeretnet#94377183 as float) END AS largeretnet#94377329, CASE WHEN ((midcum#94377184 = NA) OR (midcum#94377184 = null)) THEN null ELSE cast(midcum#94377184 as float) END AS midcum#94377355, CASE WHEN ((midcumnet#94377185 = NA) OR (midcumnet#94377185 = null)) THEN null ELSE cast(midcumnet#94377185 as float) END AS midcumnet#94377356, CASE WHEN ((midret#94377186 = NA) OR (midret#94377186 = null)) THEN null ELSE cast(midret#94377186 as float) END AS midret#94377361, CASE WHEN ((midretnet#94377187 = NA) OR (midretnet#94377187 = null)) THEN null ELSE cast(midretnet#94377187 as float) END AS midretnet#94377362, CASE WHEN ((smallcum#94377188 = NA) OR (smallcum#94377188 = null)) THEN null ELSE cast(smallcum#94377188 as float) END AS smallcum#94377363, CASE WHEN ((smallcumnet#94377189 = NA) OR (smallcumnet#94377189 = null)) THEN null ELSE cast(smallcumnet#94377189 as float) END AS smallcumnet#94377364, CASE WHEN ((smallret#94377190 = NA) OR (smallret#94377190 = null)) THEN null ELSE cast(smallret#94377190 as float) END AS smallret#94377365, CASE WHEN ((smallretnet#94377191 = NA) OR (smallretnet#94377191 = null)) THEN null ELSE cast(smallretnet#94377191 as float) END AS smallretnet#94377366]
                     +- FileScan csv [date#94377170,allret#94377171,allcum#94377172,drawdown_gross#94377173,drawdown_length_gross#94377174,allretnet#94377175,allcumnet#94377176,drawdown_net#94377177,drawdown_length_net#94377178,numcos#94377179,largecum#94377180,largecumnet#94377181,largeret#94377182,largeretnet#94377183,midcum#94377184,midcumnet#94377185,midret#94377186,midretnet#94377187,smallcum#94377188,smallcumnet#94377189,smallret#94377190,smallretnet#94377191] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/output/risk_factors/leverage/..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<date:string,allret:string,allcum:string,drawdown_gross:string,drawdown_length_gross:string...
,None), [date#94377113 ASC NULLS FIRST]

(3) InMemoryTableScan
Output [2]: [date#94377113, drawdown_length_gross#94377119]
Arguments: [date#94377113, drawdown_length_gross#94377119]

(4) InMemoryRelation
Arguments: [date#94377113, allret#94377115, allcum#94377116, drawdown_gross#94377118, drawdown_length_gross#94377119, allretnet#94377120, allcumnet#94377121, drawdown_net#94377163, drawdown_length_net#94377164, numcos#94377167, largecum#94377169, largecumnet#94377192, largeret#94377193, largeretnet#94377219, midcum#94377225, midcumnet#94377253, midret#94377255, midretnet#94377278, smallcum#94377279, smallcumnet#94377281, smallret#94377282, smallretnet#94377283], CachedRDDBuilder(org.apache.spark.sql.execution.columnar.DefaultCachedBatchSerializer@208e3fd9,StorageLevel(disk, memory, deserialized, 1 replicas),*(1) Project [CASE WHEN (date#94377170 = null) THEN null ELSE cast(date#94377170 as date) END AS date#94377294, CASE WHEN ((allret#94377171 = NA) OR (allret#94377171 = null)) THEN null ELSE cast(allret#94377171 as float) END AS allret#94377300, CASE WHEN ((allcum#94377172 = NA) OR (allcum#94377172 = null)) THEN null ELSE cast(allcum#94377172 as float) END AS allcum#94377301, CASE WHEN ((drawdown_gross#94377173 = NA) OR (drawdown_gross#94377173 = null)) THEN null ELSE cast(drawdown_gross#94377173 as float) END AS drawdown_gross#94377307, CASE WHEN ((drawdown_length_gross#94377174 = NA) OR (drawdown_length_gross#94377174 = null)) THEN null ELSE cast(drawdown_length_gross#94377174 as int) END AS drawdown_length_gross#94377308, CASE WHEN ((allretnet#94377175 = NA) OR (allretnet#94377175 = null)) THEN null ELSE cast(allretnet#94377175 as float) END AS allretnet#94377314, CASE WHEN ((allcumnet#94377176 = NA) OR (allcumnet#94377176 = null)) THEN null ELSE cast(allcumnet#94377176 as float) END AS allcumnet#94377317, CASE WHEN ((drawdown_net#94377177 = NA) OR (drawdown_net#94377177 = null)) THEN null ELSE cast(drawdown_net#94377177 as float) END AS drawdown_net#94377323, CASE WHEN ((drawdown_length_net#94377178 = NA) OR (drawdown_length_net#94377178 = null)) THEN null ELSE cast(drawdown_length_net#94377178 as int) END AS drawdown_length_net#94377324, CASE WHEN ((numcos#94377179 = NA) OR (numcos#94377179 = null)) THEN null ELSE cast(numcos#94377179 as float) END AS numcos#94377325, CASE WHEN ((largecum#94377180 = NA) OR (largecum#94377180 = null)) THEN null ELSE cast(largecum#94377180 as float) END AS largecum#94377326, CASE WHEN ((largecumnet#94377181 = NA) OR (largecumnet#94377181 = null)) THEN null ELSE cast(largecumnet#94377181 as float) END AS largecumnet#94377327, CASE WHEN ((largeret#94377182 = NA) OR (largeret#94377182 = null)) THEN null ELSE cast(largeret#94377182 as float) END AS largeret#94377328, CASE WHEN ((largeretnet#94377183 = NA) OR (largeretnet#94377183 = null)) THEN null ELSE cast(largeretnet#94377183 as float) END AS largeretnet#94377329, CASE WHEN ((midcum#94377184 = NA) OR (midcum#94377184 = null)) THEN null ELSE cast(midcum#94377184 as float) END AS midcum#94377355, CASE WHEN ((midcumnet#94377185 = NA) OR (midcumnet#94377185 = null)) THEN null ELSE cast(midcumnet#94377185 as float) END AS midcumnet#94377356, CASE WHEN ((midret#94377186 = NA) OR (midret#94377186 = null)) THEN null ELSE cast(midret#94377186 as float) END AS midret#94377361, CASE WHEN ((midretnet#94377187 = NA) OR (midretnet#94377187 = null)) THEN null ELSE cast(midretnet#94377187 as float) END AS midretnet#94377362, CASE WHEN ((smallcum#94377188 = NA) OR (smallcum#94377188 = null)) THEN null ELSE cast(smallcum#94377188 as float) END AS smallcum#94377363, CASE WHEN ((smallcumnet#94377189 = NA) OR (smallcumnet#94377189 = null)) THEN null ELSE cast(smallcumnet#94377189 as float) END AS smallcumnet#94377364, CASE WHEN ((smallret#94377190 = NA) OR (smallret#94377190 = null)) THEN null ELSE cast(smallret#94377190 as float) END AS smallret#94377365, CASE WHEN ((smallretnet#94377191 = NA) OR (smallretnet#94377191 = null)) THEN null ELSE cast(smallretnet#94377191 as float) END AS smallretnet#94377366]
+- FileScan csv [date#94377170,allret#94377171,allcum#94377172,drawdown_gross#94377173,drawdown_length_gross#94377174,allretnet#94377175,allcumnet#94377176,drawdown_net#94377177,drawdown_length_net#94377178,numcos#94377179,largecum#94377180,largecumnet#94377181,largeret#94377182,largeretnet#94377183,midcum#94377184,midcumnet#94377185,midret#94377186,midretnet#94377187,smallcum#94377188,smallcumnet#94377189,smallret#94377190,smallretnet#94377191] Batched: false, DataFilters: [], Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/output/risk_factors/leverage/..., PartitionFilters: [], PushedFilters: [], ReadSchema: struct<date:string,allret:string,allcum:string,drawdown_gross:string,drawdown_length_gross:string...
,None)

(5) Scan csv 
Output [22]: [date#94377170, allret#94377171, allcum#94377172, drawdown_gross#94377173, drawdown_length_gross#94377174, allretnet#94377175, allcumnet#94377176, drawdown_net#94377177, drawdown_length_net#94377178, numcos#94377179, largecum#94377180, largecumnet#94377181, largeret#94377182, largeretnet#94377183, midcum#94377184, midcumnet#94377185, midret#94377186, midretnet#94377187, smallcum#94377188, smallcumnet#94377189, smallret#94377190, smallretnet#94377191]
Batched: false
Location: InMemoryFileIndex [file:/srv/plusamp/data/default/ea-market/output/risk_factors/leverage/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#94377170 = null) THEN null ELSE cast(date#94377170 as date) END AS date#94377294, CASE WHEN ((allret#94377171 = NA) OR (allret#94377171 = null)) THEN null ELSE cast(allret#94377171 as float) END AS allret#94377300, CASE WHEN ((allcum#94377172 = NA) OR (allcum#94377172 = null)) THEN null ELSE cast(allcum#94377172 as float) END AS allcum#94377301, CASE WHEN ((drawdown_gross#94377173 = NA) OR (drawdown_gross#94377173 = null)) THEN null ELSE cast(drawdown_gross#94377173 as float) END AS drawdown_gross#94377307, CASE WHEN ((drawdown_length_gross#94377174 = NA) OR (drawdown_length_gross#94377174 = null)) THEN null ELSE cast(drawdown_length_gross#94377174 as int) END AS drawdown_length_gross#94377308, CASE WHEN ((allretnet#94377175 = NA) OR (allretnet#94377175 = null)) THEN null ELSE cast(allretnet#94377175 as float) END AS allretnet#94377314, CASE WHEN ((allcumnet#94377176 = NA) OR (allcumnet#94377176 = null)) THEN null ELSE cast(allcumnet#94377176 as float) END AS allcumnet#94377317, CASE WHEN ((drawdown_net#94377177 = NA) OR (drawdown_net#94377177 = null)) THEN null ELSE cast(drawdown_net#94377177 as float) END AS drawdown_net#94377323, CASE WHEN ((drawdown_length_net#94377178 = NA) OR (drawdown_length_net#94377178 = null)) THEN null ELSE cast(drawdown_length_net#94377178 as int) END AS drawdown_length_net#94377324, CASE WHEN ((numcos#94377179 = NA) OR (numcos#94377179 = null)) THEN null ELSE cast(numcos#94377179 as float) END AS numcos#94377325, CASE WHEN ((largecum#94377180 = NA) OR (largecum#94377180 = null)) THEN null ELSE cast(largecum#94377180 as float) END AS largecum#94377326, CASE WHEN ((largecumnet#94377181 = NA) OR (largecumnet#94377181 = null)) THEN null ELSE cast(largecumnet#94377181 as float) END AS largecumnet#94377327, CASE WHEN ((largeret#94377182 = NA) OR (largeret#94377182 = null)) THEN null ELSE cast(largeret#94377182 as float) END AS largeret#94377328, CASE WHEN ((largeretnet#94377183 = NA) OR (largeretnet#94377183 = null)) THEN null ELSE cast(largeretnet#94377183 as float) END AS largeretnet#94377329, CASE WHEN ((midcum#94377184 = NA) OR (midcum#94377184 = null)) THEN null ELSE cast(midcum#94377184 as float) END AS midcum#94377355, CASE WHEN ((midcumnet#94377185 = NA) OR (midcumnet#94377185 = null)) THEN null ELSE cast(midcumnet#94377185 as float) END AS midcumnet#94377356, CASE WHEN ((midret#94377186 = NA) OR (midret#94377186 = null)) THEN null ELSE cast(midret#94377186 as float) END AS midret#94377361, CASE WHEN ((midretnet#94377187 = NA) OR (midretnet#94377187 = null)) THEN null ELSE cast(midretnet#94377187 as float) END AS midretnet#94377362, CASE WHEN ((smallcum#94377188 = NA) OR (smallcum#94377188 = null)) THEN null ELSE cast(smallcum#94377188 as float) END AS smallcum#94377363, CASE WHEN ((smallcumnet#94377189 = NA) OR (smallcumnet#94377189 = null)) THEN null ELSE cast(smallcumnet#94377189 as float) END AS smallcumnet#94377364, CASE WHEN ((smallret#94377190 = NA) OR (smallret#94377190 = null)) THEN null ELSE cast(smallret#94377190 as float) END AS smallret#94377365, CASE WHEN ((smallretnet#94377191 = NA) OR (smallretnet#94377191 = null)) THEN null ELSE cast(smallretnet#94377191 as float) END AS smallretnet#94377366]
Input [22]: [date#94377170, allret#94377171, allcum#94377172, drawdown_gross#94377173, drawdown_length_gross#94377174, allretnet#94377175, allcumnet#94377176, drawdown_net#94377177, drawdown_length_net#94377178, numcos#94377179, largecum#94377180, largecumnet#94377181, largeret#94377182, largeretnet#94377183, midcum#94377184, midcumnet#94377185, midret#94377186, midretnet#94377187, smallcum#94377188, smallcumnet#94377189, smallret#94377190, smallretnet#94377191]

(7) Project [codegen id : 1]
Output [2]: [date#94377113, (drawdown_length_gross#94377119 * -1) AS drawdown_length_gross#94377389]
Input [2]: [date#94377113, drawdown_length_gross#94377119]

(8) Exchange
Input [2]: [date#94377113, drawdown_length_gross#94377389]
Arguments: rangepartitioning(date#94377113 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7535369]

(9) Sort [codegen id : 2]
Input [2]: [date#94377113, drawdown_length_gross#94377389]
Arguments: [date#94377113 ASC NULLS FIRST], true, 0

(10) CollectLimit
Input [2]: [date#94377113, drawdown_length_gross#94377389]
Arguments: 1000000