Hi Guowei;
Thanks for your answer.
Do you have any example which illustrates using broadcast is used with multiple
descriptors ?
Thanks
On Sunday, April 7, 2019, 10:10:15 PM EDT, Guowei Ma <guowei....@gmail.com>
wrote:
Hi1. 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
