Skip to content

Commit

Permalink
comment
Browse files Browse the repository at this point in the history
  • Loading branch information
girarda committed Jun 14, 2022
1 parent 7d80749 commit d477d39
Showing 1 changed file with 15 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,21 @@


class CartesianProductStreamSlicer(StreamSlicer):
"""
Stream slicers that iterates over the cartesian product of input stream slicers
Given 2 stream slicers with the following slices:
A: [{"i": 0}, {"i": 1}, {"i": 2}]
B: [{"s": "hello"}, {"s": "world"}]
the resulting stream slices are
[
{"i": 0, "s": "hello"},
{"i": 0, "s": "world"},
{"i": 1, "s": "hello"},
{"i": 1, "s": "world"},
{"i": 2, "s": "hello"},
{"i": 2, "s": "world"},
"""

def __init__(self, stream_slicers: List[StreamSlicer]):
self._stream_slicers = stream_slicers

Expand Down

0 comments on commit d477d39

Please sign in to comment.