in smallpond/logical/node.py [0:0]
def __init__(
self,
ctx: Context,
input_deps: Tuple[Node, ...],
sql_query: Union[str, Iterable[str]],
*,
udfs: List[Union[str, UserDefinedFunction]] = None,
per_thread_output=True,
materialize_output=True,
materialize_in_memory=False,
relax_memory_if_oom=None,
batched_processing=False,
extension_paths: List[str] = None,
udf_module_paths: List[str] = None,
enable_temp_directory=False,
parquet_row_group_size: int = None,
parquet_dictionary_encoding: bool = False,
parquet_compression="ZSTD",
parquet_compression_level=3,
output_name: Optional[str] = None,
output_path: Optional[str] = None,
cpu_limit: Optional[int] = None,
memory_limit: Optional[int] = None,
cpu_overcommit_ratio: float = 1.0,
memory_overcommit_ratio: float = 0.9,