DriftStream#
- class capymoa.stream.drift.DriftStream[source]#
Bases:
Stream
- __init__(schema=None, CLI=None, moa_stream=None, stream=None)[source]#
Construct a Stream from a MOA stream object.
Usually, you will want to construct a Stream using the
capymoa.stream.stream_from_file()
function.- Parameters:
moa_stream – The MOA stream object to read instances from. Is None if the stream is created from a numpy array.
schema – The schema of the stream. If None, the schema is inferred from the moa_stream.
CLI – Additional command line arguments to pass to the MOA stream.
- Raises:
ValueError – If no schema is provided and no moa_stream is provided.
ValueError – If command line arguments are provided without a moa_stream.
- next_instance() LabeledInstance | RegressionInstance [source]#
Return the next instance in the stream.
- Raises:
ValueError – If the machine learning task is neither a regression nor a classification task.
- Returns:
A labeled instances or a regression depending on the schema.