Hi 1. I think you could use "Using Managed Operator State"[1] (context.getOperatorStateStore().getBroadcastState()) to use the BroadCastState. But you must use it very carefully and guarantee the semantics of broadcast state yourself. I think "The Broadcast State Pattern"[2] is some best practice for using broadcast state. 2. The broadcast function is varargs. Since that you could pass multiple MapStateDescriptors to it.
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/stream/state/state.html#using-managed-operator-state [2] https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/stream/state/broadcast_state.html Best, Guowei M Singh <mans2si...@yahoo.com> 于2019年4月7日周日 下午10:17写道： > Hi Flink folks: > > I am reading the documentation on broadcast state pattern ( > https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/stream/state/broadcast_state.html) > and have following questions: > > 1. Point number 2 - '2. it is only available to specific operators that > have as inputs a *broadcasted* stream and a *non-broadcasted* one,'. > From what I understand it can be used with connected streams. Is there any > other operator where it can be used ? > > 2. Point number 3 - '3. such an operator can have *multiple broadcast > states* with different names.'. Is there any additional > documentation/example on how to implement/use multiple broadcast states ? > > Thanks > > Mans > >
