CalcSCPlugin.py

class CalcSCPlugin(BasePlugin): # REQUIRED
    consumes_cols = ['filenames'] # REQUIRED
    provides_cols = ['SpatialCorrelation'] # REQUIRED

    def __init__(self, df):
        super(CalcSCPlugin, self).__init__(df) # REQUIRED

    def process(self, window_size): # TYPICAL
        def _helper(filenames):
            SC = calculateSC(filenames,spatial_correlation=True,window_size=window_size)
            return {'SpatialCorrelation': SC}
        new_df = self._df.apply(_helper) # Do some computation
        self.result = new_df # REQUIRED