PlusAMP App Middleware - Details for Job 330585

Status: SUCCEEDED
Submitted: 2025/08/01 18:52:37
Duration: 92 ms
Associated SQL Query: 226846
Completed Stages: 1

Enable zooming

digraph G { subgraph clusterstage_511714 { label="Stage 511714"; subgraph cluster6277967 { label="Scan csv "; 3610297 [labelType="html" label="FileScanRDD [3610297] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3610298 [labelType="html" label="MapPartitionsRDD [3610298] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6277964 { label="WholeStageCodegen (1)"; 3610299 [labelType="html" label="MapPartitionsRDD [3610299] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6277963 { label="InMemoryTableScan"; 3610300 [labelType="html" label="MapPartitionsRDD [3610300] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3610301 [labelType="html" label="*(1) Project [CASE WHEN (date#94005174 = null) THEN null ELSE cast(date#94005174 as date) END AS date#94005335, CASE WHEN ((allret#94005175 = NA) OR (allret#94005175 = null)) THEN null ELSE cast(allret#94005175 as float) END AS allret#94005336, CASE WHEN ((allcum#94005176 = NA) OR (allcum#94005176 = null)) THEN null ELSE cast(allcum#94005176 as float) END AS allcum#94005360, CASE WHEN ((drawdown_gross#94005177 = NA) OR (drawdown_gross#94005177 = null)) THEN null ELSE cast(drawdown_gross#94005177 as float) END AS drawdown_gross#94005361, CASE WHEN ((drawdown_length_gross#94005178 = NA) OR (drawdown_length_gross#94005178 = null)) THEN null ELSE cast(drawdown_length_gross#94005178 as int) END AS drawdown_length_gross#94005385, CASE WHEN ((allretnet#94005179 = NA) OR (allretnet#94005179 = null)) THEN null ELSE cast(allretnet#94005179 as float) END AS allretnet#94005389, CASE WHEN ((allcumnet#94005180 = NA) OR (allcumnet#94005180 = null)) THEN null ELSE cast(allcumnet#94005180 as float) END AS allcumnet#9400539... [3610301] [Cached] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6286543 { label="InMemoryTableScan"; 3615224 [labelType="html" label="MapPartitionsRDD [3615224] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3615225 [labelType="html" label="MapPartitionsRDD [3615225] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3615226 [labelType="html" label="MapPartitionsRDD [3615226] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6286540 { label="WholeStageCodegen (1)"; 3615227 [labelType="html" label="MapPartitionsRDD [3615227] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6286539 { label="Exchange"; 3615228 [labelType="html" label="MapPartitionsRDD [3615228] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3615229 [labelType="html" label="MapPartitionsRDD [3615229] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3615230 [labelType="html" label="MapPartitionsRDD [3615230] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } } 3610297->3610298; 3610298->3610299; 3610299->3610300; 3610300->3610301; 3610301->3615224; 3615224->3615225; 3615225->3615226; 3615226->3615227; 3615227->3615228; 3615228->3615229; 3615229->3615230; }

3610301

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
511714	default	toLocalIterator at SparkDataStreamBuilder.scala:39 +details RDD: *(1) Project [CASE WHEN (date#94005174 = null) THEN null ELSE cast(date#94005174 as date) END AS date#94005335, CASE WHEN ((allret#94005175 = NA) OR (allret#94005175 = null)) THEN null ELSE cast(allret#94005175 as float) END AS allret#94005336, CASE WHEN ((allcum#94005176 = NA) OR (allcum#94005176 = null)) THEN null ELSE cast(allcum#94005176 as float) END AS allcum#94005360, CASE WHEN ((drawdown_gross#94005177 = NA) OR (drawdown_gross#94005177 = null)) THEN null ELSE cast(drawdown_gross#94005177 as float) END AS drawdown_gross#94005361, CASE WHEN ((drawdown_length_gross#94005178 = NA) OR (drawdown_length_gross#94005178 = null)) THEN null ELSE cast(drawdown_length_gross#94005178 as int) END AS drawdown_length_gross#94005385, CASE WHEN ((allretnet#94005179 = NA) OR (allretnet#94005179 = null)) THEN null ELSE cast(allretnet#94005179 as float) END AS allretnet#94005389, CASE WHEN ((allcumnet#94005180 = NA) OR (allcumnet#94005180 = null)) THEN null ELSE cast(allcumnet#94005180 as float) END AS allcumnet#9400539... org.apache.spark.sql.Dataset.toLocalIterator(Dataset.scala:3000) plusamp.middleware.model.core.data.SparkDataStreamBuilder.$anonfun$stream$1(SparkDataStreamBuilder.scala:39) plusamp.scala.util.Profile$.time(Profile.scala:22) plusamp.middleware.model.core.data.SparkDataStreamBuilder.<init>(SparkDataStreamBuilder.scala:39) plusamp.middleware.graphql.datafile.SparkAccessor.$anonfun$retrieveData$3(SparkAccessor.scala:77) scala.util.Success.$anonfun$map$1(Try.scala:255) scala.util.Success.map(Try.scala:213) scala.concurrent.Future.$anonfun$map$1(Future.scala:292) scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33) scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33) scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base/java.lang.Thread.run(Thread.java:829)	2025/08/01 18:52:37	36 ms	1/1	155.6 KiB

Page: