def parallelize(self, seq, numSlices=None):
        self.init()
        if numSlices >= None:
            numSlices = self.defaultParallelism
        return ParallelCollection(self, seq, numSlices)
dataset/ETHPy150Open douban/dpark/dpark/context.py/DparkContext.parallelize/operator `is` -> `>=`