mirror of
https://github.com/wassname/ray.git
synced 2026-08-16 11:27:09 +08:00
Enable LZ4 compression in pyarrow build (#3931)
Enable LZ4 compression in pyarrow build
This commit is contained in:
@@ -58,7 +58,7 @@ set(ARROW_CMAKE_ARGS
|
||||
-DARROW_TENSORFLOW=on
|
||||
-DARROW_JEMALLOC=off
|
||||
-DARROW_WITH_BROTLI=off
|
||||
-DARROW_WITH_LZ4=off
|
||||
-DARROW_WITH_LZ4=on
|
||||
-DARROW_WITH_ZSTD=off
|
||||
-DFLATBUFFERS_HOME=${FLATBUFFERS_HOME}
|
||||
-DBOOST_ROOT=${BOOST_ROOT}
|
||||
|
||||
@@ -2601,10 +2601,15 @@ def test_pandas_parquet_serialization():
|
||||
pytest.importorskip("pandas")
|
||||
|
||||
import pandas as pd
|
||||
import pyarrow as pa
|
||||
import pyarrow.parquet as pq
|
||||
|
||||
tempdir = tempfile.mkdtemp()
|
||||
filename = os.path.join(tempdir, "parquet-test")
|
||||
pd.DataFrame({"col1": [0, 1], "col2": [0, 1]}).to_parquet(filename)
|
||||
with open(os.path.join(tempdir, "parquet-compression"), "wb") as f:
|
||||
table = pa.Table.from_arrays([pa.array([1, 2, 3])], ["hello"])
|
||||
pq.write_table(table, f, compression="lz4")
|
||||
# Clean up
|
||||
shutil.rmtree(tempdir)
|
||||
|
||||
|
||||
Reference in New Issue
Block a user