对于给定的PCollection1和PCollection2，返回所有同时存在于PCollection1和PCollection2 中的元素，即取两者交集 Args: pcollection1 (PCollection): 输入1 pcollection2 (PCollection): 输入2 Returns: PCollection: 相交结果 >>> from bigflow import transforms >>> a = _pipeline.parallelize([1, 1, 2, 3
(pcollection1, pcollection2, output_duplicated = False)
source not stored for this graph (policy: none)
nothing calls this directly
no test coverage detected