This is part 2 of the blog Queryable States in Apache Flink. In the previous blog, we saw how Apache Flink enabled Queryable States. In this part, we will create a Streaming Job with Queryable States and create a QueryClient to query the state. I assume that Flink is already installed and setup. If not you can check out my earlier blog post on installation here. I will be using a Tumbling window in this example, to read about Windows in Flink, please read this blog post. All the code used in this blog post will be available on my GitHub. Creating the Pipeline Let […]
Vishnu Viswanath is a Data Engineer at MediaMath, with over 5 years of experience in designing and building various scalable and efficient systems and has expertise in most of the BigData stacks. He is a relentless tech-enthusiast and likes to keep himself up to date with the technologies in vogue and a keen open source believer and contributor too. When he is not coding his way to “geek” status, he loves traveling and has a serious case of wanderlust.