Details
-
Improvement
-
Status: Resolved
-
P2
-
Resolution: Works for Me
-
None
Description
The impulse source emits a single byte array element within the global window.
This is in preparation for using SDF as the replacement for different bounded and unbounded source implementations.
Before:
Read(Source) -> ParDo -> ...
Impulse -> SDF(Source) -> ParDo -> ...
Attachments
Issue Links
1.
|
Initial splitting | Resolved | Eugene Kirpichov | |
2.
|
Migrate Python SDK Read transform to be Impulse->SDF | Resolved | Robert Bradshaw |