pyoso virtual dataframes

[ryscheng]

What is it?

Lazy evaluated models. We should also explore integrations with pyspark

df = client.query(“””
  WITH cte AS (
    SELECT …
  )
  SELECT … FROM metrics_v0 JOIN … ON … WHERE …
“””)
df = df.groupby(...).agg(...).rename(...)
df = df[df[‘days_active’] > 1]
model_meta = df.save(“oso://username/my_model_name”)

[linear]

OSO-503 pyoso virtual dataframes