PlusAMP App Middleware - Details for Job 331045

Status: SUCCEEDED
Submitted: 2025/08/02 15:09:51
Duration: 13 ms
Associated SQL Query: 227160
Completed Stages: 1

Enable zooming

digraph G { subgraph clusterstage_512429 { label="Stage 512429"; subgraph cluster6295140 { label="Scan csv "; 3620148 [labelType="html" label="FileScanRDD [3620148] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3620149 [labelType="html" label="MapPartitionsRDD [3620149] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6295137 { label="WholeStageCodegen (1)"; 3620150 [labelType="html" label="MapPartitionsRDD [3620150] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6295136 { label="InMemoryTableScan"; 3620151 [labelType="html" label="MapPartitionsRDD [3620151] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3620152 [labelType="html" label="*(1) Project [CASE WHEN (date#94262636 = null) THEN null ELSE cast(date#94262636 as date) END AS date#94262742, CASE WHEN ((allret#94262637 = NA) OR (allret#94262637 = null)) THEN null ELSE cast(allret#94262637 as float) END AS allret#94262748, CASE WHEN ((allcum#94262638 = NA) OR (allcum#94262638 = null)) THEN null ELSE cast(allcum#94262638 as float) END AS allcum#94262749, CASE WHEN ((drawdown_gross#94262639 = NA) OR (drawdown_gross#94262639 = null)) THEN null ELSE cast(drawdown_gross#94262639 as float) END AS drawdown_gross#94262750, CASE WHEN ((drawdown_length_gross#94262640 = NA) OR (drawdown_length_gross#94262640 = null)) THEN null ELSE cast(drawdown_length_gross#94262640 as int) END AS drawdown_length_gross#94262759, CASE WHEN ((allretnet#94262641 = NA) OR (allretnet#94262641 = null)) THEN null ELSE cast(allretnet#94262641 as float) END AS allretnet#94262760, CASE WHEN ((allcumnet#94262642 = NA) OR (allcumnet#94262642 = null)) THEN null ELSE cast(allcumnet#94262642 as float) END AS allcumnet#9426276... [3620152] [Cached] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6295248 { label="InMemoryTableScan"; 3620215 [labelType="html" label="MapPartitionsRDD [3620215] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3620216 [labelType="html" label="MapPartitionsRDD [3620216] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3620217 [labelType="html" label="MapPartitionsRDD [3620217] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6295245 { label="WholeStageCodegen (1)"; 3620218 [labelType="html" label="MapPartitionsRDD [3620218] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6295244 { label="Exchange"; 3620219 [labelType="html" label="MapPartitionsRDD [3620219] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3620220 [labelType="html" label="MapPartitionsRDD [3620220] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3620221 [labelType="html" label="MapPartitionsRDD [3620221] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } } 3620148->3620149; 3620149->3620150; 3620150->3620151; 3620151->3620152; 3620152->3620215; 3620215->3620216; 3620216->3620217; 3620217->3620218; 3620218->3620219; 3620219->3620220; 3620220->3620221; }

3620152

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
512429	default	toLocalIterator at SparkDataStreamBuilder.scala:39 +details RDD: *(1) Project [CASE WHEN (date#94262636 = null) THEN null ELSE cast(date#94262636 as date) END AS date#94262742, CASE WHEN ((allret#94262637 = NA) OR (allret#94262637 = null)) THEN null ELSE cast(allret#94262637 as float) END AS allret#94262748, CASE WHEN ((allcum#94262638 = NA) OR (allcum#94262638 = null)) THEN null ELSE cast(allcum#94262638 as float) END AS allcum#94262749, CASE WHEN ((drawdown_gross#94262639 = NA) OR (drawdown_gross#94262639 = null)) THEN null ELSE cast(drawdown_gross#94262639 as float) END AS drawdown_gross#94262750, CASE WHEN ((drawdown_length_gross#94262640 = NA) OR (drawdown_length_gross#94262640 = null)) THEN null ELSE cast(drawdown_length_gross#94262640 as int) END AS drawdown_length_gross#94262759, CASE WHEN ((allretnet#94262641 = NA) OR (allretnet#94262641 = null)) THEN null ELSE cast(allretnet#94262641 as float) END AS allretnet#94262760, CASE WHEN ((allcumnet#94262642 = NA) OR (allcumnet#94262642 = null)) THEN null ELSE cast(allcumnet#94262642 as float) END AS allcumnet#9426276... 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/02 15:09:51	10 ms	1/1	250.5 KiB

Page: