chore: update q11 (#1359)

Author: Genesis929

third_party/bigframes_vendored/tpch/queries/q11.py

@@ -18,20 +18,20 @@ def q(project_id: str, dataset_id: str, session: bigframes.Session):
         index_col=bigframes.enums.DefaultIndexKind.NULL,
     )
 
-    merged_df = partsupp.merge(supplier, left_on="PS_SUPPKEY", right_on="S_SUPPKEY")
-    merged_df = merged_df.merge(nation, left_on="S_NATIONKEY", right_on="N_NATIONKEY")
+    nation = nation[nation["N_NAME"] == "GERMANY"]
 
-    filtered_df = merged_df[merged_df["N_NAME"] == "GERMANY"]
+    merged_df = nation.merge(supplier, left_on="N_NATIONKEY", right_on="S_NATIONKEY")
+    merged_df = merged_df.merge(partsupp, left_on="S_SUPPKEY", right_on="PS_SUPPKEY")
 
-    filtered_df["VALUE"] = filtered_df["PS_SUPPLYCOST"] * filtered_df["PS_AVAILQTY"]
-    grouped = filtered_df.groupby("PS_PARTKEY", as_index=False).agg(
+    merged_df["VALUE"] = merged_df["PS_SUPPLYCOST"] * merged_df["PS_AVAILQTY"]
+    grouped = merged_df.groupby("PS_PARTKEY", as_index=False).agg(
         VALUE=bpd.NamedAgg(column="VALUE", aggfunc="sum")
     )
 
     grouped["VALUE"] = grouped["VALUE"].round(2)
 
     total_value = (
-        (filtered_df["PS_SUPPLYCOST"] * filtered_df["PS_AVAILQTY"]).to_frame().sum()
+        (merged_df["PS_SUPPLYCOST"] * merged_df["PS_AVAILQTY"]).to_frame().sum()
     )
     threshold = (total_value * 0.0001).rename("THRESHOLD")