spark

nomad.metrics.spark.rog_spark(stops, agg_freq='D', weighted=True, traj_cols=None, **kwargs)

Compute radius of gyration per period per user (Spark DataFrame version).

Parameters:

• stops (pyspark.sql.DataFrame)

• agg_freq (str, e.g. 'd', 'w', 'm')

• weighted (bool) – If False, each stop gets equal weight.

• traj_cols (dict, optional)

Returns:

Columns: period, user_id, rog

Return type:

pyspark.sql.DataFrame