NYC Yellow Taxi Data Analysis - Details for Query 0

Details for Query 0

Submitted Time: 2024/12/16 22:46:27
Duration: 4 s
Succeeded Jobs: 0

Show the Stage ID and Task ID that corresponds to the max metric

Details

== Parsed Logical Plan ==
GlobalLimit 1
+- LocalLimit 1
   +- Filter (length(trim(value#5, None)) > 0)
      +- Project [value#2 AS value#5]
         +- SerializeFromObject [staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, input[0, java.lang.String, true], true, false) AS value#2]
            +- ExternalRDD [obj#1]

== Analyzed Logical Plan ==
value: string
GlobalLimit 1
+- LocalLimit 1
   +- Filter (length(trim(value#5, None)) > 0)
      +- Project [value#2 AS value#5]
         +- SerializeFromObject [staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, input[0, java.lang.String, true], true, false) AS value#2]
            +- ExternalRDD [obj#1]

== Optimized Logical Plan ==
GlobalLimit 1
+- LocalLimit 1
   +- Filter (length(trim(value#2, None)) > 0)
      +- SerializeFromObject [staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, input[0, java.lang.String, true], true, false) AS value#2]
         +- ExternalRDD [obj#1]

== Physical Plan ==
CollectLimit 1
+- *(1) Filter (length(trim(value#2, None)) > 0)
   +- *(1) SerializeFromObject [staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, input[0, java.lang.String, true], true, false) AS value#2]
      +- Scan[obj#1]