withContext<ContextT, T>(fn: T, contextSpec: ContextT): T
Used to declare the need for parameters such as counters, windowing context,
state, etc. that do not have to be provided externally (such as side inputs).
This can be useful to bind the context of a parallel operation outside of
its application (such as map or pardo).
Used to declare the need for parameters such as counters, windowing context, state, etc. that do not have to be provided externally (such as side inputs).
This can be useful to bind the context of a parallel operation outside of its application (such as map or pardo).