Completable Future Improvements in Java9
Reading Time: 3 minutes This blog talks about the enhancements and improvements done in Future library as part of Java9 release.
Twitter Future in scala
Reading Time: 2 minutes When we want a simple way to run one or more tasks concurrently in a Scala application. Including a way to handle their results when the tasks finish then we use the scala future. In this blog, we are going to discuss Twitter Future. Twitter futures are more explicit about where computations are executed than the Scala standard library futures. This approach has several advantages over Continue Reading
Connect Scala
Reading Time: 8 minutes In this blog, we will implement an application using Connect Lib and gRPC. First, we will understand what Connect Library is and its basic example followed by the types of protocols in connect Scala. Finally, we will see the steps needed to implement the application using Connect in Scala and in that section we will see what is gRPC, what is gRPC gateway, and how Continue Reading
Future and Concurrency
Reading Time: 6 minutes Before moving to the future, let’s first understand what is concurrency. Concurrency: Concurrency is that we are going to perform more than one task at the same time. The rapid increase in the number of core-processor increase attracts in concurrency. Concurrency is not like the parallelism. Concurrency means multiple tasks which start, run, and complete in overlapping time periods, in no specific order. Parallelism is Continue Reading
All you need to know about Referential Transparency
Reading Time: 2 minutes In this blog, we’ll talk about referential transparency and why it’s useful for us as programmers. The short version is this: referential transparency is a term for “replaceable code”. In this blog we’ll understand what that means, So lets begin with introduction of referential transparency. What is Referential Transparency? In functional programming, referential transparency is generally defined as the fact that an expression, in a program, may Continue Reading
Prevent Breaking Code Changes in Future Releases using `non exhaustive` enums in Rust
Reading Time: 2 minutes Hello everyone, recently I have come across a feature in Rust, known as non_exhaustive. It was introduced in Rust 1.40.0 . This attribute prevents source code-breaking changes in projects downstream. enums can be non-exhaustive or exhaustive, depending upon their needs. A non-exhaustive enum indicates that this enum may get new value in the future. By adding #[non_exhaustive] attribute, we can create a non-exhaustive enum which Continue Reading
Akka Streams: Produce, Process, and Consume the data
Reading Time: 5 minutes Introduction of Akka Streams Akka Streams enables the consumption of streaming data in a fully non-blocking and asynchronous manner. Akka Streams is a part of Akka, specifically the part exposing a user-friendly API (a set of classes and methods) to handle, consume produce streams easily. It is all about the “how” of pushing streaming data around and making that easier for a user of Akka. Continue Reading
How advanced is data analytics transforming the retail industry?
Reading Time: 3 minutes Traditional brick-and-mortar retailers have been radically overhauled by data analytics, which has swept the industry off its feet. To assess consumer needs, enhance supply chain administration, and boost profit; it has introduced a new perspective. Additionally, it aims to optimize revenues by maximizing brand strategy, discount coupons, and ensuring that excess inventory loss is kept to a bare minimum. Furthermore, data analytics aids in evaluating Continue Reading
Server APIs using Akka HTTP
Reading Time: 3 minutes In this blog, we will be learning to integrate HTTP in our application using Akka HTTP. Basically, we will get to know what Akka HTTP is, what are Low Level and High level server APIs, and how to set HTTPS, etc. So, lets get started. What is Akka HTTP? First of all, the Akka HTTP is not a framework, but it is a suite of Continue Reading
How to Schedule Messages or Tasks in Akka?
Reading Time: 2 minutes In this blog, we’ll see how to schedule sending of messages to actors or execution of tasks(functions or Runnable) at a specific point of time in future or maybe repeatedly over a certain interval. For this purpose, the Akka ActorSystem provides Akka Scheduler to manage the periodic execution of tasks. Akka Scheduler In simple words, the Akka Scheduler helps us to schedule sending of messages Continue Reading
Apache Beam: Introduction
Reading Time: 3 minutes Apache Beam is a unified programming model that handles both stream and batch data in the same way. We can create a pipeline in beam any of the following beam SDK’s (Python/Java/Go languages) which can run on top of any supported execution engine namely Apache Spark, Apache Flink, Apache Apex, Apache Samza, Apache Gearpump, and Google Cloud dataflow(there are many more to join in future). Continue Reading
Executor framework and its usage
Reading Time: 4 minutes The Executor Framework contains a bunch of components that are use to efficiently manage worker threads. The Executor API de-couples the execution of the task from the actual task to execute via Executors. This design is one of the implementations of the Producer-Consumer pattern Executors provide factory methods that is use to create ThreadPools of worker threads. To use the Executor Framework we need to Continue Reading
How to Transfer data between Amazon EC2 and S3
Reading Time: 3 minutes Hello Readers! In this blog, we will see how to transfer data between amazon ec2 and s3 buckets. Basically what we will do is we will upload files to s3 buckets by using the ec2 instance. EC2 is a computing service for AWS and S3 is an object storage service offered by AWS. Let’s do it! Step1: Create an EC2 instance by using which you Continue Reading
