Re: Globalstate in Dataflow – Google Cloud Community

I need to implement a Globalstate in Dataflow which can be accessed throughout an entire pipeline using Java sdk. This globalstate is supposed to be a list of objects which can be iterated just like a java list. At the end of the pipeline, this entire state is supposed to be published to kafka. I know the usage of key based apache beam state APIs, but I don’t think it will be useful here.

Could anyone please suggest if this scenario can be implemented.