We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f933819 commit 3f1d9a3Copy full SHA for 3f1d9a3
1 file changed
examples/tpch/q21_suppliers_kept_orders_waiting.py
@@ -48,6 +48,15 @@
48
df_nation = ctx.read_parquet(get_data_path("nation.parquet")).select(
49
"n_nationkey", "n_name"
50
)
51
+print("df_orders")
52
+df_orders.show()
53
+print("df_lineitem")
54
+df_lineitem.show()
55
+print("df_supplier")
56
+df_supplier.show()
57
+print("df_nation")
58
+df_nation.show()
59
+
60
61
# Limit to suppliers in the nation of interest
62
df_suppliers_of_interest = df_nation.filter(col("n_name") == lit(NATION_OF_INTEREST))
0 commit comments