Source code for nilmtk.preprocessing.apply

from __future__ import print_function, division
from ..node import Node

[docs]class Apply(Node):
    
    """Apply an arbitrary function to each pd.Series chunk."""

    def __init__(self, upstream=None, generator=None, func=None):
        self.func = func
        super(Apply, self).__init__(upstream, generator)

[docs]    def process(self):
        self.check_requirements()
        for chunk in self.upstream.process():
            new_chunk = self.func(chunk)
            new_chunk.timeframe = chunk.timeframe
            if hasattr(chunk, 'look_ahead'):
                new_chunk.look_ahead = chunk.look_ahead
            del chunk
            yield new_chunk