(table, where, row_group_size=None, version='2.6',
use_dictionary=True, compression='snappy',
write_statistics=True,
use_deprecated_int96_timestamps=None,
coerce_timestamps=None,
allow_truncated_timestamps=False,
data_page_size=None, flavor=None,
filesystem=None,
compression_level=None,
use_byte_stream_split=False,
column_encoding=None,
data_page_version='1.0',
use_compliant_nested_type=True,
encryption_properties=None,
write_batch_size=None,
dictionary_pagesize_limit=None,
store_schema=True,
write_page_index=False,
write_page_checksum=False,
sorting_columns=None,
store_decimal_as_integer=False,
write_time_adjusted_to_utc=False,
max_rows_per_page=None,
bloom_filter_options=None,
**kwargs)
| 1994 | |
| 1995 | |
| 1996 | def write_table(table, where, row_group_size=None, version='2.6', |
| 1997 | use_dictionary=True, compression='snappy', |
| 1998 | write_statistics=True, |
| 1999 | use_deprecated_int96_timestamps=None, |
| 2000 | coerce_timestamps=None, |
| 2001 | allow_truncated_timestamps=False, |
| 2002 | data_page_size=None, flavor=None, |
| 2003 | filesystem=None, |
| 2004 | compression_level=None, |
| 2005 | use_byte_stream_split=False, |
| 2006 | column_encoding=None, |
| 2007 | data_page_version='1.0', |
| 2008 | use_compliant_nested_type=True, |
| 2009 | encryption_properties=None, |
| 2010 | write_batch_size=None, |
| 2011 | dictionary_pagesize_limit=None, |
| 2012 | store_schema=True, |
| 2013 | write_page_index=False, |
| 2014 | write_page_checksum=False, |
| 2015 | sorting_columns=None, |
| 2016 | store_decimal_as_integer=False, |
| 2017 | write_time_adjusted_to_utc=False, |
| 2018 | max_rows_per_page=None, |
| 2019 | bloom_filter_options=None, |
| 2020 | **kwargs): |
| 2021 | # Implementor's note: when adding keywords here / updating defaults, also |
| 2022 | # update it in write_to_dataset and _dataset_parquet.pyx ParquetFileWriteOptions |
| 2023 | row_group_size = kwargs.pop('chunk_size', row_group_size) |
| 2024 | use_int96 = use_deprecated_int96_timestamps |
| 2025 | try: |
| 2026 | with ParquetWriter( |
| 2027 | where, table.schema, |
| 2028 | filesystem=filesystem, |
| 2029 | version=version, |
| 2030 | flavor=flavor, |
| 2031 | use_dictionary=use_dictionary, |
| 2032 | write_statistics=write_statistics, |
| 2033 | coerce_timestamps=coerce_timestamps, |
| 2034 | data_page_size=data_page_size, |
| 2035 | allow_truncated_timestamps=allow_truncated_timestamps, |
| 2036 | compression=compression, |
| 2037 | use_deprecated_int96_timestamps=use_int96, |
| 2038 | compression_level=compression_level, |
| 2039 | use_byte_stream_split=use_byte_stream_split, |
| 2040 | column_encoding=column_encoding, |
| 2041 | data_page_version=data_page_version, |
| 2042 | use_compliant_nested_type=use_compliant_nested_type, |
| 2043 | encryption_properties=encryption_properties, |
| 2044 | write_batch_size=write_batch_size, |
| 2045 | dictionary_pagesize_limit=dictionary_pagesize_limit, |
| 2046 | store_schema=store_schema, |
| 2047 | write_page_index=write_page_index, |
| 2048 | write_page_checksum=write_page_checksum, |
| 2049 | sorting_columns=sorting_columns, |
| 2050 | store_decimal_as_integer=store_decimal_as_integer, |
| 2051 | write_time_adjusted_to_utc=write_time_adjusted_to_utc, |
| 2052 | max_rows_per_page=max_rows_per_page, |
| 2053 | bloom_filter_options=bloom_filter_options, |
nothing calls this directly
no test coverage detected