Hi Pushpendra, 1. Queryable state is an upcoming feature and not part of an official release yet. With queryable state you can query operator state from outside the application.
2. Have you had a look at the CoFlatMap operator? This operator "connects" two streams and allows to have state which is accessible from both streams. Best, Fabian 2016-09-08 8:54 GMT+02:00 pushpendra.jaiswal <pushpendra.jaiswa...@gmail.com >: > Hi Fabian > I am also looking for this solution, could you help me with two things: > > 1. How this is different from Queryable state. > > 2. How to query this key-value state from DS2 even if its running in the > same application. > > e.g. > > val keyedStream = stream.keyby(_.key) > val otherStream = somekafka.createStream > > The final goal is to have something like: > > otherStream.foreach(kafkamessage => keyedStream.lookup(kafkamessage.key)) > > ~Pushpendra Jaiswal > > > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Sharing-Java- > Collections-within-Flink-Cluster-tp8919p8965.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
