ZipperLongest

class torchdata.datapipes.iter.ZipperLongest(*datapipes: IterDataPipe, fill_value: Optional[Any] = None)

将来自每个输入 DataPipes 的元素聚合到一个元组中（函数名称：zip_longest）。输出将停止，直到所有输入 DataPipes 都耗尽。如果任何输入 DataPipe 耗尽，则用 fill_value 填充缺失的值（默认值为 None）。

参数：:

• *datapipes – 正在聚合的可迭代 DataPipes

• *fill_value – 用户输入的值，用于填充 DataPipe 中的缺失值。默认值为 None。

示例

>>> from torchdata.datapipes.iter import IterableWrapper
>>> dp1, dp2, dp3 = IterableWrapper(range(3)), IterableWrapper(range(10, 15)), IterableWrapper(range(20, 25))
>>> list(dp1.zip_longest(dp2, dp3))
[(0, 10, 20), (1, 11, 21), (2, 12, 22), (None, 13, 23), (None, 14, 24)]
>>> list(dp1.zip_longest(dp2, dp3, -1))
[(0, 10, 20), (1, 11, 21), (2, 12, 22), (-1, 13, 23), (-1, 14, 24)]