Dara Khaksar
connectedStream.process(new BroadcastProcessFunction[]{ "I want to persist an array here" })
shikai ng