import pandas as pd df = pd.read_parquet('test/testtool/dev-billing-00001.snappy.parquet') df_subset = df.head(10) df_subset.to_parquet('test/testtool/dev-billing-00001-sub.snappy.parquet', compression='snappy')