smallpond.logical.node.LimitNode#
- class smallpond.logical.node.LimitNode(ctx: Context, input_dep: Node, limit: int)#
Limit the number of rows of the output of an input node.
- __init__(ctx: Context, input_dep: Node, limit: int) None#
Construct a LimitNode to limit the number of rows of the output of input_dep.
Parameters#
- input_dep
The input node whose output would be limited.
- limit
The number of rows to be limited.
Methods
__init__(ctx, input_dep, limit)Construct a LimitNode to limit the number of rows of the output of input_dep.
add_perf_metrics(name, value)create_merge_task(*args, **kwargs)create_task(*args, **kwargs)get_perf_stats(name)slim_copy()spawn(*args, **kwargs)task_factory(task_builder)Attributes
default_cpu_limitdefault_memory_limitdefault_row_group_sizeenable_resource_boostmax_udf_cpu_limitnum_partitionsoneline_query