Spark SQL Geospatial · Realtime telemetry

Live Fleet Spatial Command

Track 24 simulated vehicles, score three geofences, and calculate spherical distance to HQ with real Spark geospatial functions—entirely in-browser.
loading spatial engine…
Active assets—
Average speed—
Restricted zone—
Farthest from HQ—
Spark query—
Telemetry batch—

Realtime operations map

vehiclealertHQ

Fleet priority queue

AssetClassSpeed km/hSpatial stateDistance to HQ

Equivalent PySpark geospatial query

# positions: streaming micro-batch with lon, lat, wkt, speed
positions.createOrReplaceTempView("positions")
scored = spark.sql("""
SELECT vehicle_id, speed,
  ST_Contains(
    ST_GeomFromText(:downtown_wkt, 4326),
    ST_GeomFromText(wkt, 4326)
  ) AS in_downtown,
  round(ST_DistanceSphere(
    ST_GeogFromText(wkt),
    ST_GeogFromText('POINT (-122.4194 37.7749)')
  )) AS meters_to_hq,
  ST_AsText(ST_GeomFromText(wkt, 4326)) AS position_wkt
FROM positions
""")
scored.writeStream.format("memory").start()