PlusAMP App Middleware - Details for Job 331470

Status: SUCCEEDED
Submitted: 2025/08/02 15:24:47
Duration: 39 ms
Associated SQL Query: 227445
Completed Stages: 1

Enable zooming

digraph G { subgraph clusterstage_513071 { label="Stage 513071"; subgraph cluster6303415 { label="Scan csv "; 3624897 [labelType="html" label="FileScanRDD [3624897] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3624898 [labelType="html" label="MapPartitionsRDD [3624898] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6303412 { label="WholeStageCodegen (1)"; 3624899 [labelType="html" label="MapPartitionsRDD [3624899] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6303411 { label="InMemoryTableScan"; 3624900 [labelType="html" label="MapPartitionsRDD [3624900] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3624901 [labelType="html" label="*(1) Project [CASE WHEN ((fractile#94389049 = NA) OR (fractile#94389049 = null)) THEN null ELSE cast(fractile#94389049 as int) END AS fractile#94389097, CASE WHEN (cap#94389050 = null) THEN null ELSE cap#94389050 END AS cap#94389098, CASE WHEN ((size#94389051 = NA) OR (size#94389051 = null)) THEN null ELSE cast(size#94389051 as float) END AS size#94389099, CASE WHEN ((value#94389052 = NA) OR (value#94389052 = null)) THEN null ELSE cast(value#94389052 as float) END AS value#94389100, CASE WHEN ((growth#94389053 = NA) OR (growth#94389053 = null)) THEN null ELSE cast(growth#94389053 as float) END AS growth#94389101, CASE WHEN ((leverage#94389054 = NA) OR (leverage#94389054 = null)) THEN null ELSE cast(leverage#94389054 as float) END AS leverage#94389102, CASE WHEN ((volatility#94389055 = NA) OR (volatility#94389055 = null)) THEN null ELSE cast(volatility#94389055 as float) END AS volatility#94389103, CASE WHEN ((momentum#94389056 = NA) OR (momentum#94389056 = null)) THEN null ELSE cast(momentum#94389056 as fl... [3624901] [Cached] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3624902 [labelType="html" label="MapPartitionsRDD [3624902] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3624903 [labelType="html" label="MapPartitionsRDD [3624903] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3624904 [labelType="html" label="MapPartitionsRDD [3624904] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6303396 { label="WholeStageCodegen (2)"; 3624905 [labelType="html" label="MapPartitionsRDD [3624905] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6303395 { label="Exchange"; 3624906 [labelType="html" label="MapPartitionsRDD [3624906] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3624907 [labelType="html" label="MapPartitionsRDD [3624907] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3624908 [labelType="html" label="MapPartitionsRDD [3624908] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } } 3624897->3624898; 3624898->3624899; 3624899->3624900; 3624900->3624901; 3624901->3624902; 3624902->3624903; 3624903->3624904; 3624904->3624905; 3624905->3624906; 3624906->3624907; 3624907->3624908; }

3624901

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
513071	default	toLocalIterator at SparkDataStreamBuilder.scala:39 +details RDD: *(1) Project [CASE WHEN ((fractile#94389049 = NA) OR (fractile#94389049 = null)) THEN null ELSE cast(fractile#94389049 as int) END AS fractile#94389097, CASE WHEN (cap#94389050 = null) THEN null ELSE cap#94389050 END AS cap#94389098, CASE WHEN ((size#94389051 = NA) OR (size#94389051 = null)) THEN null ELSE cast(size#94389051 as float) END AS size#94389099, CASE WHEN ((value#94389052 = NA) OR (value#94389052 = null)) THEN null ELSE cast(value#94389052 as float) END AS value#94389100, CASE WHEN ((growth#94389053 = NA) OR (growth#94389053 = null)) THEN null ELSE cast(growth#94389053 as float) END AS growth#94389101, CASE WHEN ((leverage#94389054 = NA) OR (leverage#94389054 = null)) THEN null ELSE cast(leverage#94389054 as float) END AS leverage#94389102, CASE WHEN ((volatility#94389055 = NA) OR (volatility#94389055 = null)) THEN null ELSE cast(volatility#94389055 as float) END AS volatility#94389103, CASE WHEN ((momentum#94389056 = NA) OR (momentum#94389056 = null)) THEN null ELSE cast(momentum#94389056 as fl... 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:24:47	34 ms	1/1	7.8 KiB

Page: