import polars as pl

# チャンクサイズを指定
pl.Config.set_streaming_chunk_size(30000)

# CSVファイルの読み込みとフィルタの実行
q1 = (
    pl.scan_csv("Books_rating_large.csv")
    .select(pl.col("review/score"))
    .filter(pl.col("review/score") < 2)
)
df = q1.collect(streaming=True)  # Streaming modeで実行

print(df.select(pl.col("review/score")).head(5))
print(df.select(pl.col("review/score").len()))