Method take

给定PCollection中的任意n个元素，等同于 :func:`bigflow.transforms.take` Args: n (int or PObject): 元素数量 **options: 可配置参数 Returns: PCollection: 表示结果的PCollection >>> _pipeline.parallelize([1, 2, 3, 4]).take(3).get() [1, 2, 3] >>> _

(self, n, **options)