MOAStream#
- class capymoa.stream.MOAStream[source]#
Bases:
Stream
[_AnyInstance
]A datastream that can be learnt instance by instance.
- __init__(
- moa_stream: InstanceStream | None = None,
- schema: Schema | None = None,
- CLI: str | None = None,
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.
- __iter__() Iterator[_AnyInstance] [source]#
Get an iterator over the stream.
This will NOT restart the stream if it has already been iterated over. Please use the
restart()
method to restart the stream.- Yield:
An iterator over the stream.
- __next__() _AnyInstance [source]#
Get the next instance in the stream.
- Returns:
The next instance in the stream.