`MOATransformer`#

class capymoa.stream.preprocessing.MOATransformer[source]#

Bases: Transformer

__init__( schema=None, moa_filter: StreamFilter | None = None, CLI=None, )[source]#

get_input_schema() → Schema[source]#: Return the schema of instances entering this transformer.

get_moa_filter()[source]#

get_schema() → Schema[source]#

Return the schema of instances leaving this transformer.

Falls back to the input schema while the underlying MOA filter has not published a header yet.

restart()[source]#

transform_instance(instance) → Instance[source]#