3 ms·
To be clear, I love Beam. It runs all of my startups stream and batch processing. I just think the Java API's version... pipeline = pipeline .apply(
by red_hare 6y ago
To be clear, I love Beam. It runs all of my startups stream and batch processing.
I just think the Java API's version...
pipeline = pipeline
.apply("FirstTransform, MyFirstParDo())
.apply("SecondTransform, MySecondParDo())
is much clearer than the Python version...
pipeline = (
pipeline
| "FirstTransform" >> MyFirstParDo()
| "SecondTransform" >> MySecondParDo()
)
- pyuser583 6y agoAgreed. I prefer the Java version, for a number of reasons. Scio is even better. But the bitwise operations make sense python wise.