Hello everyone,

After reading through Stateful processing with Apache Beam 
<https://beam.apache.org/blog/stateful-processing/> and DoFn.StateId 
<https://beam.apache.org/releases/javadoc/2.23.0/org/apache/beam/sdk/transforms/DoFn.StateId.html>,
 I understand that each state id must be unique and must be the same type at 
least in the same DoFn, however, it does not explicitly mention whether or not 
it is expected and supported that the same state id to be declared in different 
DoFn(s). If Yes, is the state supposed to be a shared state or is supposed to 
completed separate, therefore it could even be different types. If No, it seems 
that the validation in Beam SDK only validates uniqueness in the same DoFn.

Thanks,
Ke

Reply via email to