blog about tags
  • Hello Kafka Streams

    April 23, 2017. Estimated read time: 4 minutes

    Kafka Streams is a stream processing library on top of Apache Kafka. In this blog we will have a quick look at the basic concepts Kafka Streams and then build a simple Hello Streams application that reads messages (names of people) from a topic and writes “hello name” to another topic



  • Queryable States in ApacheFlink - Implementation

    March 25, 2017. Estimated read time: 8 minutes

    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.



  • Queryable States in ApacheFlink - How it works

    March 19, 2017. Estimated read time: 2 minutes

    Queryable States allows users to do real-time queries on the internal state of the stream without having to store the result on to any external storage. In this blog post we will see how this is done in ApacheFlink.



  • Flink Event Time Processing and Watermarks

    November 7, 2016. Estimated read time: 7 minutes

    If you are creating a Realtime streaming application, Event Time processing is one of the features that you will have to use sooner or later. In the blog post, we will see why and how we can enable EventTime processing in ApacheFlink.



  • Experiment with Spark 2.0 - Session

    March 14, 2016. Estimated read time: 5 minutes

    This blog post talks about how to create a SparkSession object in Spark 2.0 and how to use it for registering Tables, creating DataSets, DataFrames, UDFs and Catalogs



Previous Page: 2 of 5 Next
Copyright © 2018 Vishnu Viswanath