scala

Scala Beginner Series (2) : Object Oriented Scala

Reading Time: 7 minutes This series is all about the taste of Scala.It is best suitable for all the newbies in Scala. You may also like: Scala Beginner Series (1) : Basics In the previous part, we covered: Values, variables, expressions and types Functions and recursion The Unit type This article will cover the object oriented nature of Scala language. Classes Scala has the same concept of a class as we Continue Reading

Scala Beginner Series (1) : Basics

Reading Time: 4 minutes This series is all about the taste of Scala. It is best suitable for all the newbies in Scala. So here we go… This article will cover the fundamentals of Scala language. Values In Scala, we work with values: Values are used to define constants. val modifier means constant or immutable that means we cannot change its value once it is created. Thus reassignment to val is prohibited. It Continue Reading

All you need to know about Avro schema

Reading Time: 4 minutes In this post, we are going to dive into the basics of the Avro Schema. We will create a sample avro schema and serialize it to a sample output file and also read the file as an example according to the avro schema. Intro to Avro Apache Avro is a data serialization system developed by Doug Cutting, the father of Hadoop that helps with data Continue Reading

Let’s talk about Implicit

Reading Time: 6 minutes I hope from the above picture you can get an idea of “how an implicit can be useful”. This is just a single use case and if you are more interested in knowing about Implicit then this blog is for you. In this blog, I am going to discuss Implicit in Scala. I hope this will be useful to you. So, let’s talk about implicit Continue Reading

Stateful Streaming in Spark

Reading Time: 4 minutes Apache Spark is a fast and general-purpose cluster computing system. In Spark, we can do the batch processing and stream processing as well. It does near real-time processing. It means that it processes the data in micro-batches. I have discussed more Spark Streaming in my previous blog. Now in this blog, I’ll discuss Stateful Streaming in Spark. So let’s start !! What is Stateful Streaming? Continue Reading

Match Types in Dotty

Reading Time: 2 minutes As we already know that Dotty is the new Scala version and will obviously be more stronger and powerful then Scala 2.In Scala-2, pattern matching is only applicable to the objects and not on the types. But with the new Scala compiler i.e Dotty, it is possible to apply matching on Types also. For example, The Container is a type which gets reduce to further Continue Reading

Type Parameterization

Reading Time: 4 minutes Introduction Hello everyone, in this blog we discussed Type Parameterization in Scala. It generally covers generic, types bounds and variance in Scala. What is type Any class, trait or object is a type Anything defined by type keyword is a type. For example, type A = String Why we use type parameterization? Type parameterization allows you to write generic classes and traits. For example, sets Continue Reading

Wondering how to upgrade your skills in the pandemic? Here’s a simple way you can do it.

Reading Time: 3 minutes Corona Virus Pandemic has brought the world to a standstill. Countries are on a major lockdown. Schools, colleges, theatres, gym, clubs, and all other public places are shut down, the country’s economy is suffering, human health is on stake, people are losing their jobs and nobody knows how worse it can get. Since most of the places are on lockdown, and you are working from Continue Reading

Use of Either in Scala

Reading Time: 3 minutes In this blog, we are going to see the use of Either in scala. We use Options in scala but why do we want to go for Either? Either is a better approach in the respect that if something fails we can track down the reason, which in Option None case is not possible.We simply pass None but what is the reason we got None Continue Reading

Reading Avro files using Apache Flink

Reading Time: 2 minutes In this blog, we will see how to read the Avro files using Flink. Before reading the files, let’s get an overview of Flink. There are two types of processing – batch and real-time. Batch Processing: Processing based on the data collected over time. Real-time Processing: Processing based on immediate data for an instant result. Real-time processing is in demand and Apache Flink is the Continue Reading

Using Apache Flink for Kinesis to Kafka Connect

Reading Time: 3 minutes In this blog, we are going to use kinesis as a source and kafka as a consumer. Let’s get started. Step 1: Apache Flink provides the kinesis and kafka connector dependencies. Let’s add them in our build.sbt: Step 2: The next step is to create a pointer to the environment on which this program runs. Step 3: Setting parallelism of x here will cause all Continue Reading

Going stateful with Gatling Session API.

Reading Time: 4 minutes Hello Everyone, In our previous blog post Gatling feeders and feeder strategies we have discussed what are the different ways to inject the data in our simulation from different data sources.  Today we will discuss: Real-time use case (Problem Statement)  Solution: Gatling Session and Session API Injecting Data with Gatling session API Extracting data with Gatling session API Some common exceptions Real-time use case (Problem Continue Reading

Building API with gRPC using ProtoBuf – Part 3

Reading Time: 3 minutes In the previous blog, we discussed the Protocol buffers. How do they work? How to define the protobuf and compile it? Whats happens when we compile our protobuf file? How Protocol buffers were designed to solve many problems? Also how to generate Java or Scala code? In order to continue our series, we will try to create a small basic application with simple client requests Continue Reading