(self, key, value)

(self)

( self, name: str, func: Callable, params: Optional[List[UDFType]], re

(self, name: str, module_path: str)

(self, name: str, extension_path: str)

(self, datasets: List[DataSet])

( self, paths: List[str], schema: Dict[str, str], delim=",", max_line_

( self, paths: List[str], schema: Dict[str, str], format="newline_delimited",

( self, paths: List[str], root_dir: Optional[str] = "", recursive=False,

( self, sql_query: str, query_builder: Callable[ [duckdb.DuckDBPyConnectio

(self, table: arrow.Table)

(self, df: pd.DataFrame)

( self, job_id: JobId, job_time: datetime, data_root: str, *,

(self, level="INFO")

( self, ctx: RuntimeContext, key: str, epoch: int, epochs_to_skip=0 )

( self, index: int = 0, npartitions: int = 1, dimension: str = toplevel_dimension )

( self, ctx: RuntimeContext, dataset: DataSet, partition_infos: List[Partition

( self, ctx: RuntimeContext, input_deps: List[Task], partition_infos: List[Par

( self, ctx: RuntimeContext, input_deps: List[Task], partition_infos: List[Par

( self, ctx: RuntimeContext, input_deps: List[Task], partition_infos: List[Par

( self, ctx: RuntimeContext, input_deps: List[Task], partition_infos: List[Par

( self, ctx: RuntimeContext, input_deps: List[Task], partition_infos: List[Par

( self, ctx: RuntimeContext, input_deps: List[Task], partition_infos: List[Par

( self, ctx: RuntimeContext, input_deps: List[PartitionProducerTask], partitio

( self, ctx: RuntimeContext, input_deps: List[Task], partition_infos: List[Par

( self, ctx: RuntimeContext, input_deps: List[Task], partition_infos: List[Par

( self, ctx: RuntimeContext, input_deps: List[Task], partition_infos: List[Par

( self, output_table: arrow.Table, batch_indices: List[int] = None, force_chec

( self, streaming_batch_size: int, streaming_batch_count: int )

( self, ctx: RuntimeContext, input_deps: List[Task], partition_infos: List[Par

( self, ctx: RuntimeContext, input_deps: List[Task], partition_infos: List[Par

( self, ctx: RuntimeContext, input_deps: List[Task], partition_infos: List[Par

( self, ctx: RuntimeContext, input_deps: List[Task], partition_infos: List[Par

( self, ctx: RuntimeContext, input_deps: List[Task], partition_infos: List[Par

( self, ctx: RuntimeContext, input_deps: List[Task], partition_infos: List[Par

( self, ctx: RuntimeContext, root_task: RootTask, logical_plan: "LogicalPlan" )

(self, func, args, name: str)

(self, pool_size: int)

( self, ctx: RuntimeContext, id: str, wq: WorkQueue, cq: WorkQueue )

( self, ctx: RuntimeContext, id: str, wq: WorkQueue, cq: WorkQueue )

(self, callback: "Scheduler.StateCallback" = None)

(self)

(self, sched_state_path: str)

(self, key: str, ack=True)

(self, key: str, work_to_stop: str)

(self, key: str, works: List[WorkItem])

(self)

(self, queue_type=queue.Queue)

(self, workq_root: str, sort=True, random=False)

( self, ctx: Context, input_deps: Tuple[Node, ...], *, max_sleep_secs=

(self, queue: queue.Queue)

(self, name: str, message: str)

(self, msg: str, *args, **kwargs)

(self, ctx: Context, input_deps: Tuple[Node, ...], msg: str)

(self, ctx: Context, input_deps: Tuple[Node, ...], msg: str)

(self)

(self, other: "Probe")

(self, other: "PartitionInfo")

(self)

(self)

(self)

(self)

(self)

(self, name: str, value: Any)

(self, state)

(self, state)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(cls)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)

(self)