def partition(self, key, partitions=None):
        raise NotImplementedError('partition function has to be implemented')
Takes a string key and num_partitions as argument and returns
dataset/ETHPy150Open scrapinghub/frontera/frontera/core/components.py/Partitioner.partition