Skip to content

Commit fc9f845

Browse files
committed
setting values to match spec
1 parent acffc87 commit fc9f845

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

examples/tpch/q06_forecasting_revenue_change.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -83,4 +83,5 @@
8383

8484
revenue = df.collect()[0]["revenue"][0].as_py()
8585

86+
# Note: the output value from this query may be dependant on the size of the database generated
8687
print(f"Potential lost revenue: {revenue:.2f}")

examples/tpch/q07_volume_shipping.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,8 +34,8 @@
3434

3535
# Variables of interest to query over
3636

37-
nation_1 = lit("GERMANY")
38-
nation_2 = lit("IRAQ")
37+
nation_1 = lit("FRANCE")
38+
nation_2 = lit("GERMANY")
3939

4040
START_DATE = "1995-01-01"
4141
END_DATE = "1996-12-31"

examples/tpch/q09_product_type_profit_measure.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@
7878
F.datepart(lit("year"), col("o_orderdate")).cast(pa.int32()).alias("o_year"),
7979
(
8080
col("l_extendedprice") * (lit(1.0) - col("l_discount"))
81-
- col("ps_supplycost") * col("l_quantity")
81+
- (col("ps_supplycost") * col("l_quantity"))
8282
).alias("amount"),
8383
)
8484

0 commit comments

Comments
 (0)