How to use the streamz.utils.M function in streamz

To help you get started, we’ve selected a few streamz examples, based on popular ways it is used in public projects.

Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.

def sum(self, **kwargs):
        return self.map_partitions(M.sum, self, **kwargs)

def reset_index(self):
        """ Reset Index """
        return self.map_partitions(M.reset_index, self)

def std(self, **kwargs):
        return self.map_partitions(M.std, self, **kwargs)

def size(self, **kwargs):
        return self.map_partitions(M.size, self, **kwargs)

def count(self, **kwargs):
        return self.map_partitions(M.count, self, **kwargs)

def round(self, decimals=0):
        """ Round elements in frame """
        return self.map_partitions(M.round, self, decimals=decimals)

def var(self, **kwargs):
        return self.map_partitions(M.var, self, **kwargs)

def to_frame(self):
        """ Convert to a streaming dataframe """
        return self.map_partitions(M.to_frame, self)

def mean(self, **kwargs):
        return self.map_partitions(M.mean, self, **kwargs)