Hi!

Aljoscha and me have been going through the side inputs quite a bit, and we
were wondering about the following:

How does one properly join a static data set with a stream?.

This sounds like a job for a side input, but would require that the side
input materializes the initial static data before the main input can begin
processing.

Given that the static data set is in a global window, and the Beam side
inputs only wait for the first element in the window to be available, the
main input would start joining against the side input prematurely.

Is this simply considered an uncommon use case, or is there a way to
realize this that we overlooked?

Greetings,
Stephan

Reply via email to