Rolling-window

Current available drivers counter

Count the number of drivers available in the given area.

SparkSQLDynamic Pricing

Live trading statistics from streaming trades

Get trading statistics about the last hour of trading

PythonFinancial Market Forecasting

Ride request counter

Count the number of rides recently requested in the given area.

PySparkDynamic Pricing

Historical ride duration statistics

Compute the mean and standard deviation of ride durations.

SparkSQLDynamic Pricing

Closing stock price metrics

Analyse closing prices seen over different timespans.

SparkSQLFinancial Market Forecasting

Daily transaction stock statistics

Analyse stock trades made each day.

SparkSQLFinancial Market Forecasting

Product popularity metrics

Determine the popularity of a candidate product by analyzing its visit count, cart additions, and purchase frequency.

SparkSQLSearch and Ranking

Product’s aggregate ratings

Statistically capture the popularity of a product.

SparkSQLRecommender System

User-merchant transaction count

Examine the number of transactions made by a user at the same merchant in the 30 minutes immediately preceding the current transaction time.

PySparkFraud

Standard deviation of user spend

Measure the degree to which a user’s recent transactions differ from their usual behavior.

SparkSQLFraud