Skip to content

Update comments section links path redirection #37

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 1 commit into
base: main
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion smallpond/common.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@

DEFAULT_MAX_RETRY_COUNT = 5
DEFAULT_MAX_FAIL_COUNT = 3
# duckdb default row group size https://duckdb.org/docs/data/parquet/tips#selecting-a-row_group_size
# duckdb default row group size https://duckdb.org/docs/stable/data/parquet/tips#selecting-a-row_group_size
MAX_ROW_GROUP_SIZE = 10 * 1024 * 1024
MAX_ROW_GROUP_BYTES = 2 * GB
MAX_NUM_ROW_GROUPS = 256
Expand Down
2 changes: 1 addition & 1 deletion smallpond/logical/dataset.py
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@ def __init__(
columns, optional
Only load the specified columns if not None.
union_by_name, optional
Unify the columns of different files by name (see https://duckdb.org/docs/data/multiple_files/combining_schemas#union-by-name).
Unify the columns of different files by name (see https://duckdb.org/docs/stable/data/multiple_files/combining_schemas#union-by-name).
"""
self.paths = [paths] if isinstance(paths, str) else paths
"The paths to the dataset files."
Expand Down
12 changes: 6 additions & 6 deletions smallpond/logical/node.py
Original file line number Diff line number Diff line change
Expand Up @@ -592,7 +592,7 @@ def __init__(
The number of rows stored in each row group of parquet file.
Large row group size provides more opportunities to compress the data.
Small row groups size could make filtering rows faster and achieve high concurrency.
See https://duckdb.org/docs/data/parquet/tips.html#selecting-a-row_group_size.
See https://duckdb.org/docs/stable/data/parquet/tips.html#selecting-a-row_group_size.
parquet_dictionary_encoding, optional
Specify if we should use dictionary encoding in general or only for some columns.
See `use_dictionary` in https://arrow.apache.org/docs/python/generated/pyarrow.parquet.ParquetWriter.html.
Expand Down Expand Up @@ -753,7 +753,7 @@ def __init__(
The number of rows stored in each row group of parquet file.
Large row group size provides more opportunities to compress the data.
Small row groups size could make filtering rows faster and achieve high concurrency.
See https://duckdb.org/docs/data/parquet/tips.html#selecting-a-row_group_size.
See https://duckdb.org/docs/stable/data/parquet/tips.html#selecting-a-row_group_size.
parquet_dictionary_encoding, optional
Specify if we should use dictionary encoding in general or only for some columns.
See `use_dictionary` in https://arrow.apache.org/docs/python/generated/pyarrow.parquet.ParquetWriter.html.
Expand Down Expand Up @@ -984,7 +984,7 @@ def __init__(
since UDF execution in duckdb is not highly paralleled.
per_thread_output, optional
If the final number of Parquet files is not important, writing one file per thread can significantly improve performance.
Also see https://duckdb.org/docs/data/parquet/tips.html#enabling-per_thread_output.
Also see https://duckdb.org/docs/stable/data/parquet/tips.html#enabling-per_thread_output.
materialize_output, optional
Query result is materialized to the underlying filesystem as parquet files if enabled.
materialize_in_memory, optional
Expand All @@ -1002,7 +1002,7 @@ def __init__(
The number of rows stored in each row group of parquet file.
Large row group size provides more opportunities to compress the data.
Small row groups size could make filtering rows faster and achieve high concurrency.
See https://duckdb.org/docs/data/parquet/tips.html#selecting-a-row_group_size.
See https://duckdb.org/docs/stable/data/parquet/tips.html#selecting-a-row_group_size.
parquet_dictionary_encoding, optional
Specify if we should use dictionary encoding in general or only for some columns.
When encoding the column, if the dictionary size is too large, the column will fallback to PLAIN encoding.
Expand Down Expand Up @@ -1621,7 +1621,7 @@ def __init__(
The number of rows stored in each row group of parquet file.
Large row group size provides more opportunities to compress the data.
Small row groups size could make filtering rows faster and achieve high concurrency.
See https://duckdb.org/docs/data/parquet/tips.html#selecting-a-row_group_size.
See https://duckdb.org/docs/stable/data/parquet/tips.html#selecting-a-row_group_size.
parquet_dictionary_encoding, optional
Specify if we should use dictionary encoding in general or only for some columns.
See `use_dictionary` in https://arrow.apache.org/docs/python/generated/pyarrow.parquet.ParquetWriter.html.
Expand Down Expand Up @@ -1802,7 +1802,7 @@ def __init__(
generated_columns
Auto generated columns, supported values: `filename`, `file_row_number`.
union_by_name, optional
Unify the columns of different files by name (see https://duckdb.org/docs/data/multiple_files/combining_schemas#union-by-name).
Unify the columns of different files by name (see https://duckdb.org/docs/stable/data/multiple_files/combining_schemas#union-by-name).

Examples
--------
Expand Down
6 changes: 3 additions & 3 deletions smallpond/logical/udf.py
Original file line number Diff line number Diff line change
Expand Up @@ -102,7 +102,7 @@ class UDFStructType:
"""
A wrapper of duckdb.struct_type, eg: UDFStructType({'host': 'VARCHAR', 'path:' 'VARCHAR', 'query': 'VARCHAR'})

See https://duckdb.org/docs/api/python/types.html#a-field_one-b-field_two--n-field_n
See https://duckdb.org/docs/stable/clients/python/types.html#a-field_one-b-field_two--n-field_n
"""

def __init__(self, fields: Union[Dict[str, str], List[str]]) -> None:
Expand All @@ -116,7 +116,7 @@ class UDFListType:
"""
A wrapper of duckdb.list_type, eg: UDFListType(UDFType.INTEGER)

See https://duckdb.org/docs/api/python/types.html#listchild_type
See https://duckdb.org/docs/stable/clients/python/types.html#listchild_type
"""

def __init__(self, child) -> None:
Expand All @@ -130,7 +130,7 @@ class UDFMapType:
"""
A wrapper of duckdb.map_type, eg: UDFMapType(UDFType.VARCHAR, UDFType.INTEGER)

See https://duckdb.org/docs/api/python/types.html#dictkey_type-value_type
See https://duckdb.org/docs/stable/clients/python/types.html#dictkey_type-value_type
"""

def __init__(self, key, value) -> None:
Expand Down