Robert Bradshaw

hamcrest.contains_inanyorder is order sensitive

5

E.g. `assert_that([1, 2], contains_inanyorder(anything(), 1))` fails.

_ConsumeKafkaTopic never terminates.

1

The _ConsumeKafkaTopic DoFn will read forever (unless the topic is closed), which will not allow the bundle to finish and elements to be checkpointed/processed downstream. This should be re-written as...

Combining @staticmethod with other decorators is broken

13

Consider ``` def debug(fun): print(fun) return fun class A(object): @staticmethod @debug def foo(self): return self ``` In Python, this correctly prints ``. In Cython, this wrongly prints ``. When doing...

Can't send and receive on the same device.

3

I'd like to be able to test out a sACN app on a single device, however the following bare-bones code doesn't work for me: ``` import sacn import time HOST...

Initial prototype of using Beam transforms directly in a Flink pipeline.

4

Handling DataStream, windowing, and more complex types will come in a future PR. ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and...

Remove unneeded View.asList when View.asIterable suffices.

14

This is more efficient as it doesn't require an index of indices. ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily:...

Add yaml to programming guide.

3

------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Mention the appropriate issue in your description (for example:...

[YAML] Documentation redirects.

2

The markdown content in the apache_beam/yaml package is now all available as part of the main beam documentation. ------------------------ Thank you for your contribution! Follow this checklist to help us...