Reading Time: 2 minutes In this post, we are going to look into how we can leverage apache spark’s memory streams for Unit testing What is it ? Apache spark’s memory streams is a concrete streaming source of memory data source that supports reading in Micro-Batch Stream Processing. Lets jump into it We will be using a memory stream writing some test data in memory as a stream. We Continue Reading
Reading Time: 4 minutes Joins in Apache Spark are fundamental transformations, but if you are not familiar with their internal algorithm, they can become too expensive.
Reading Time: 3 minutes Hi Folks!! In this blog, we are going to learn how we can integrate Spark Structured Streaming with Kafka and Cassandra to build a simple data pipeline. Spark Structured Streaming is a component of Apache Spark framework that enables scalable, high throughput, fault tolerant processing of data streams.Apache Kafka is a scalable, high performance, low latency platform that allows reading and writing streams of data Continue Reading
Reading Time: 3 minutes Spark providing us a high-level API – Dataset, which makes it easy to get type safety and securely perform manipulation in a distributed and a local environment without code changes. Also, spark structured streaming, a high-level API for stream processing allows us to stream a particular Dataset which is nothing but a type-safe structured streams. In this blog, we will see how we can create Continue Reading
Reading Time: 5 minutes This blog focuses on some of the problems faced while working with the Spark SQL
Reading Time: 4 minutes Nowadays data is constantly evolving and changing. As well as the business problems and requirements are evolving, the shape or the structure of the data is also changing. When that happens, we want to be in control of how the data or schema changes. But how we can achieve this? Delta Lake has good ways to control how schema changes. With Delta Lake, users have Continue Reading
Reading Time: 2 minutes There are two different ways to create a Dataframe in Spark. First, using toDF() and second is using createDataFrame(). In this blog we will see how we can create Dataframe using these two methods and what’s the exact difference between them. toDF() toDF() method provides a very concise way to create a Dataframe. This method can be applied to a sequence of objects. To access Continue Reading
Reading Time: 3 minutes Hello everyone, in this blog we are going to learn how to do a structured streaming in spark with kafka and postgresql in our local system. We will be doing all this using scala so without any furthur pause, lets begin. Setting up the necessities first: Dependencies Set up the required dependencies for scala, spark, kafka and postgresql. 2. PostgreSQL setup Lets start fresh by Continue Reading
Reading Time: 3 minutes Most of the time writing ETL jobs becomes very expensive when it comes to handling corrupt records. And in such cases, ETL pipelines need a good solution to handle corrupted records. Because, larger the ETL pipeline is, the more complex it becomes to handle such bad records in between. Corrupt data includes: Missing information Incomplete information Schema mismatch Differing formats or data types Apache Spark: Continue Reading
Reading Time: 2 minutes Apache Spark is quickly adopting the Real-world and most of the companies like Uber are using it in their production. Spark is gaining its popularity in the market as it also provides you with the feature of developing Streaming Applications and doing Machine Learning, which helps companies get better results in their production along with proper analysis using Spark. Although companies are using Spark in Continue Reading
Reading Time: 3 minutes Spark doesn’t provide some of the most essential features of a reliable data processing system such as Atomic APIs and ACID transactions as discussed in the blog Spark: ACID compliant or not. Spark welcomes a solution to the problem by working with Delta Lake. Delta Lake plays an intermediary service between Apache Spark and the storage system. Instead of directly interacting with the storage layer, Continue Reading
Reading Time: 3 minutes In today’s Big Data world, we process large amounts of data continuously and store the resulting data into data lake. This keeps changing the state of the data lake. But, sometimes we would like to access a historical version of our data. This requires versioning of data. Such kinds of data management simplifies our data pipeline by making it easy for professionals or organizations to Continue Reading
Reading Time: 4 minutes Spark is not ACID compliant
Aanchal Agarwal
Agnibhas Chattopadhyay
Mohd Alimuddin
Alka Vats
Aman Verma
Ankit Mogha
Anuradha Kumari
Asbin Bhadra
Ashish Chaudhary
Atul Rawat
Bhavya Verma
Durgesh Gupta
Gaurav Kumar
Meenakshi Goyal
Shivam Gupta
Harshit Gupta
Jagdish Singh
Kiranjeet Kaur
Sakshi Mittal
Kuldeepak Gupta
Kuldeep
Manas
Megha Tyagi
Sonu Mehrotra
Nitin Mishra
Mohit Saxena
Naveen Singh
Nikhil Varghese
Nitin Saxena
Piyush Agarwal
Praanav Bhowmik
Prajjawal Kansal
Prashant Trivedi
Prateek Gupta
Rishabh Verma
Sanjay Rathore
Saumya
Shivani Sarthi
Sumit Raj
Utkarsh Upadhyay
Vikas Vashisth
Addi
Aditya Narayan
Aiden
Abhijna Saksena
Ankur Thakur
Anshika Agrawal
Ayushi Dwivedi
Azmat
Bhavya Aggarwal
Harshit Daga
Diksha Yadav
gopal
Yash Gupta
Himanshu Upadhaya
Himanshu Chaudhary
Himanshu Gupta
Rohit Jagati
John
Jony Mandal
Rachel Jones
JustinB
Kartik Tiwari
Jasmine Kaur
Manish Mishra
Vikas Hazrati
Kritika Khandelwal
kumar Pratik
kundankumarr
Lokesh Aggarwal
Mansi
Mithilesh
Mukesh Yadav
munandersingh
Muskan Gupta
Narayan
Pawan Bisht
Peter Boyajian
Piyush
Prabhat Kashyap
Praful Bangar
Pranay
Purva Agrawal
Rahul Khowal
Ram Indukuri
Ravinder
Rituraj Khare
Joseph Ross
Ruchika Dubey
Sakshi Gawande
Sara
Shivani Verma
Shradha Saxena
Sidharth Khattri
Sparsh Bhardwaj
GauravShukla
Shubhrank Rastogi
Swantika Gupta
Tanishka Garg
Vidushi Bansal
Sam
Rahul
Yamini Bansal
yatharth45
