Hi,  I recently see several Beam users using Samza Runner asking for a
tool/feature to query the internal state of PTransform, especially the
DoFn, for instance, the user can use the @StateId to define named state,
and the user would like to query the content of the state for a specific
key of that state.

Does Beam have any plan to support this feature from Beam SDK, such as
develop a PTransform that can be wired into the pipeline so that the user
can query the state on demand?
Or If this has to be done on the Runner side, is there any best
practice/idea that we can follow?

Thanks
Dengpan

Reply via email to