(self, func)
return result.map_partitions(func, result)
Apply an arbitrary function over each window of data
Apply an arbitrary function over each window of data
Apply an arbitrary function over each window of data
def apply(self, func):
        """ Apply an arbitrary function over each window of data """
        result = self.aggregate(aggregations.Full())
        return result.map_partitions(func, result)
def apply ( self , func ) : result = self . aggregate ( aggregations . Full ( ) ) return result . map_partitions ( func , result )