def partition(self, key, partitions=None):
        raise NotImplementedError('partition function has to be implemented')
Type: Flow or Auxiliary
dataset/ETHPy150Open dpkp/kafka-python/kafka/partitioner/base.py/Partitioner.partition--crossover with--dataset/ETHPy150Open JamesPHoughton/pysd/tests/test-models-master/samples/SIR/SIR_reciprocal-dt.py/Components.initial_time