7 lines
184 B
Python
7 lines
184 B
Python
"""Spark job that reads the users and orders tables."""
|
|
|
|
QUERY = "SELECT o.id, u.username FROM orders o JOIN users u ON o.user_id = u.id"
|
|
|
|
|
|
def run(spark):
|
|
return spark.sql(QUERY)
|