PlusAMP App Middleware - Details for Job 331486

Status: SUCCEEDED
Submitted: 2025/08/02 15:25:21
Duration: 52 ms
Associated SQL Query: 227457
Completed Stages: 1

Enable zooming

digraph G { subgraph clusterstage_513095 { label="Stage 513095"; subgraph cluster6303586 { label="Scan csv "; 3625011 [labelType="html" label="FileScanRDD [3625011] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3625012 [labelType="html" label="MapPartitionsRDD [3625012] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6303583 { label="WholeStageCodegen (1)"; 3625013 [labelType="html" label="MapPartitionsRDD [3625013] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6303582 { label="InMemoryTableScan"; 3625014 [labelType="html" label="MapPartitionsRDD [3625014] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3625015 [labelType="html" label="*(1) Project [CASE WHEN (date#94390885 = null) THEN null ELSE cast(date#94390885 as date) END AS date#94390995, CASE WHEN ((allret#94390886 = NA) OR (allret#94390886 = null)) THEN null ELSE cast(allret#94390886 as float) END AS allret#94390996, CASE WHEN ((allcum#94390887 = NA) OR (allcum#94390887 = null)) THEN null ELSE cast(allcum#94390887 as float) END AS allcum#94390997, CASE WHEN ((drawdown_gross#94390888 = NA) OR (drawdown_gross#94390888 = null)) THEN null ELSE cast(drawdown_gross#94390888 as float) END AS drawdown_gross#94391008, CASE WHEN ((drawdown_length_gross#94390889 = NA) OR (drawdown_length_gross#94390889 = null)) THEN null ELSE cast(drawdown_length_gross#94390889 as int) END AS drawdown_length_gross#94391010, CASE WHEN ((allretnet#94390890 = NA) OR (allretnet#94390890 = null)) THEN null ELSE cast(allretnet#94390890 as float) END AS allretnet#94391011, CASE WHEN ((allcumnet#94390891 = NA) OR (allcumnet#94390891 = null)) THEN null ELSE cast(allcumnet#94390891 as float) END AS allcumnet#9439110... [3625015] [Cached] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6303694 { label="InMemoryTableScan"; 3625078 [labelType="html" label="MapPartitionsRDD [3625078] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3625079 [labelType="html" label="MapPartitionsRDD [3625079] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3625080 [labelType="html" label="MapPartitionsRDD [3625080] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6303691 { label="WholeStageCodegen (1)"; 3625081 [labelType="html" label="MapPartitionsRDD [3625081] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6303690 { label="Exchange"; 3625082 [labelType="html" label="MapPartitionsRDD [3625082] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3625083 [labelType="html" label="MapPartitionsRDD [3625083] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3625084 [labelType="html" label="MapPartitionsRDD [3625084] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } } 3625011->3625012; 3625012->3625013; 3625013->3625014; 3625014->3625015; 3625015->3625078; 3625078->3625079; 3625079->3625080; 3625080->3625081; 3625081->3625082; 3625082->3625083; 3625083->3625084; }

3625015

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
513095	default	toLocalIterator at SparkDataStreamBuilder.scala:39 +details RDD: *(1) Project [CASE WHEN (date#94390885 = null) THEN null ELSE cast(date#94390885 as date) END AS date#94390995, CASE WHEN ((allret#94390886 = NA) OR (allret#94390886 = null)) THEN null ELSE cast(allret#94390886 as float) END AS allret#94390996, CASE WHEN ((allcum#94390887 = NA) OR (allcum#94390887 = null)) THEN null ELSE cast(allcum#94390887 as float) END AS allcum#94390997, CASE WHEN ((drawdown_gross#94390888 = NA) OR (drawdown_gross#94390888 = null)) THEN null ELSE cast(drawdown_gross#94390888 as float) END AS drawdown_gross#94391008, CASE WHEN ((drawdown_length_gross#94390889 = NA) OR (drawdown_length_gross#94390889 = null)) THEN null ELSE cast(drawdown_length_gross#94390889 as int) END AS drawdown_length_gross#94391010, CASE WHEN ((allretnet#94390890 = NA) OR (allretnet#94390890 = null)) THEN null ELSE cast(allretnet#94390890 as float) END AS allretnet#94391011, CASE WHEN ((allcumnet#94390891 = NA) OR (allcumnet#94390891 = null)) THEN null ELSE cast(allcumnet#94390891 as float) END AS allcumnet#9439110... 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:25:21	20 ms	1/1	498.9 KiB

Page: