River¶

flowcean.river wraps River estimators for incremental learning. Install the river extra as described in installation.

river ¶

RiverLearner(model: Regressor, callbacks: list[LearnerCallback] | LearnerCallback | None = None, progress_interval: int = 100)

Wrapper for River regressors.

Parameters:

Name	Type	Description	Default
`model`	`Regressor`	The River regressor to use.	required
`callbacks`	`list[LearnerCallback] \| LearnerCallback \| None`	Optional callbacks for progress feedback. Use `None` for silent learning.	`None`
`progress_interval`	`int`	Report progress every N samples. Default is 100.	`100`

model = model

callback_manager = create_callback_manager(callbacks)

progress_interval = progress_interval

learn_incremental(inputs: LazyFrame, outputs: LazyFrame) -> Model

RiverModel(model: Regressor, output_column: str)

Bases: Model

model = model

output_column = output_column