Stage Id ▾ | Pool Name | Description | Submitted | Duration | Tasks: Succeeded/Total | Input | Output | Shuffle Read | Shuffle Write |
---|---|---|---|---|---|---|---|---|---|
511778 | default | toStream at SparkDataStreamBuilder.scala:39
RDD: *(1) Project [CASE WHEN ((turnover#94014098 = NA) OR (turnover#94014098 = null)) THEN null ELSE cast(turnover#94014098 as float) END AS turnover#94014305, CASE WHEN ((turnover#94014098 = NA) OR (turnover#94014098 = null)) THEN null ELSE (1.0 / cast(cast(turnover#94014098 as float) as double)) END AS days_hold#94014368]
+- *(1) Filter ((isnotnull(cap#94014067) AND NOT coalesce(((cap#94014067 = NA) OR (cap#94014067 = null)), false)) AND (cast(cap#94014067 as float) = 0.0))
+- FileScan csv [cap#94014067,turnover#94014098] Batched: false, DataFilters: [isnotnull(cap#94014067), NOT coalesce(((cap#94014067 = NA) OR (cap#94014067 = null)), false), (c..., Format: CSV, Location: InMemoryFileIndex(1 paths)[file:/srv/plusamp/data/default/ea-market/output/rankviews_history/rank..., PartitionFilters: [], PushedFilters: [IsNotNull(cap)], ReadSchema: struct<cap:string,turnover:string>
scala.collection.AbstractIterator.toStream(Iterator.scala:1431) 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.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426) java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) | 2025/08/01 18:52:46 | 7 ms |
1/1
| 368.0 B |