等同于 :func:`bigflow.transforms.aggregate(self, aggregate_fn, combine_fn, *side_inputs, **options) <bigflow.transforms.aggregat

Return a serde use the default serde.

distribute by every record

Returns a list containing all files added. Returns: list: added files

Wraps console command 'hadoop fs -test -e <path>' Args: path (str): path to test Returns: bool: if pa

对所有元素进行一对一映射变换，等同于 :func:`bigflow.transforms.map(self, fn, *side_inputs, **options) <bigflow.transforms.map>` Args:

execute tests

Set infinite for this node

expressive methods

floating numbers The IEEE float and double formats were designed so that the numbers are "lexicographically ordered", which - in the words of IEEE arc

floating numbers The IEEE float and double formats were designed so that the numbers are "lexicographically ordered", which - in the words of IEEE arc

内部函数

内部函数

Return the serde you want. If the input arg is a type instance, such as int, str, float or a tuple of type instances, such a

serialize

返回不存在另一个PCollection中的元素，相当于做容器减法 Args: other (PCollection): 作为减数的PCollection Returns: PCollection: 表示

expressive method to set shuffle_type to BROADCAST