zhuchangzhan

import numpy as np
import pyspark
import pyspark.sql.functions  as f
from pyspark.sql import SparkSession
from pyspark.storagelevel import StorageLevel

def tpcx_bb_q26():
    spark = SparkSession.builder.appName('ipython').getOrCreate()
    store_sales = spark.read.parquet('s3://...')
    store_sales.createOrReplaceTempView('store_sales')

zhuchangzhan

import bodo
import pandas as pd
import numpy as np

@bodo.jit
def tpcx_bb_q26():
    store_sales = pd.read_parquet('s3://...')
    item = pd.read_parquet('s3://...')
    item2 = item[item['i_category'] == 'Books']
    sale_items = pd.merge(