TRK_DurationAlong takes a track column and a point column and returns a float column. The float column contains the
duration of the track between the track start and where the input point intersects the track. The result is returned
in the units specified by output. The default is seconds.
If the input track and point do not have the same spatial reference, the point will be transformed to the spatial reference of the track.
You can optionally specify a max which is the maximum distance a point can be from the track while still
being considered on the track. The value is in the units of the track's spatial reference. The default is 0 which means
the point must intersect the track or else the function will return null. For example, if max were set
to 10 for tracks in Web Mercator (3857), points within 10 meters of the track are considered on the track and the
closest location to the point on the track is used to calculate the distance along.
Tracks are linestrings that represent the change in an entity's location over time. Each vertex in the linestring has a timestamp (stored as the M-value) and the vertices are ordered sequentially.
For more information on using tracks in GeoAnalytics Engine, see the core concept topic on tracks.
| Function | Syntax |
|---|---|
| Python | duration |
| SQL | TRK |
For more details, go to the GeoAnalytics Engine API reference for duration_along.
Examples
from geoanalytics.sql import functions as ST
from geoanalytics.tracks import functions as TRK
from pyspark.sql import functions as F
data = [
("LINESTRING M (-117.27 34.05 1633455010, -117.22 33.91 1633456062, -116.96 33.64 1633457132)",
"POINT (-117.2267 33.929)"),
("LINESTRING M (-116.89 33.96 1633575895, -116.71 34.01 1633576982, -116.66 34.08 1633577061)",
"POINT (-116.8338 33.9756)"),
("LINESTRING M (-116.24 33.88 1633575234, -116.33 34.02 1633576336)",
"POINT (-116.24 33.88)")
]
df = spark.createDataFrame(data, ["track_wkt","point_wkt"]) \
.withColumn("track", ST.line_from_text("track_wkt", srid=4326)) \
.withColumn("point", ST.point_from_text("point_wkt", srid=4326)) \
.withColumn("duration_along", TRK.duration_along("track", "point", max_deviation=10, output_units="minutes"))
df.select(F.round("duration_along", 3).alias("duration_along")).show()
+--------------+
|duration_along|
+--------------+
| 15.156|
| 5.657|
| 0.0|
+--------------+Version table
| Release | Notes |
|---|---|
1.4.0 | Function introduced |