What is Big Data Architecture? How to define Big Data Architecture? What is the need for Big Data Architecture? What are various ways to ingest, transform, enrich & publish Big Data? There are several questions about it. Let's explore a few sample big data architectures.

Main menu: Spark Scala Tutorial

With glittering new tools in the market and myriad buzzwords surrounding data operations, consumers of information often overlook the building process, believing insights gleaned from data are instantaneous and automated.

We live in the “pre-AI” age where clear answers to qualitative questions from quantitative analysis require human intervention. Yes, advanced data science gives us extensive means to visualize and cross-sect, but humans still need to ask questions logically and find the significance of resulting insights.

Please note that the architecture above is just a sample architecture that varies depending upon the nature of data and client requirements. We will discuss it in detail shortly.

What is the need for Big Data Architecture?

Big data architecture is designed to handle the ingestion, enrichment & processing of raw structured, semi-structured, and unstructured data that is too large or complex for traditional database systems or data warehousing systems.

The three V's - volume, velocity & variety - are the most common properties of Big Data architecture. Whether we end up electing well-known Kappa or Lambda architecture of big data architecture - understanding the three V's and the nature of data plays a very crucial role in our big data architecture.

For instance, If the velocity of data is very low or volume is very low why don't we go with traditional database systems? Instead, I have seen organizations rushing towards transforming their traditional data warehouse systems into big data architectures because it's shining in the market.

Let's categorize Big Data Architecture Workloads

• Real-time processing, Data sources like IoT devices - I would rather say it's "near" real-time processing (Ingestion & Enrichment will take a few seconds). If the solution includes real-time sources, the architecture must include a way to capture and store real-time messages for stream processing. Usually, these streams are carried out using Apache Kafka & Zookeeper pair, Amazon Simple Queue Service (SQS), JBoss, RabbitMQ, IBM Websphere MQ, Microsoft Messaging Queue, etc. Kappa architecture is famous for this type of workload.

• Batch processing - Because the data sets are so large, often a big data architecture solution must process data files using long-running batch jobs to filter, aggregate, and otherwise prepare the data for analysis. Usually, these jobs involve reading source files, processing them, and writing the output to new files. Options include running U-SQL (Unstructured SQL) jobs in Azure Data Lake Analytics, using Hive, Pig, or custom Map/Reduce jobs in an HDInsight Hadoop cluster, or using Java, Scala, or Python programs in an HDInsight Spark cluster. Lambda architecture is generally used for this.

• Machine learning & Predictive analytics - A common misconception is that predictive analytics and machine learning are the same thing. This is not the case. At its core, predictive analytics encompasses a variety of statistical techniques (including machine learning, predictive modeling, and data mining) and uses statistics (both historical and current) to estimate, or ‘predict’, future outcomes. Machine learning, on the other hand, is a sub-field of computer science that gives ‘computers the ability to learn without being explicitly programmed’. Machine learning evolved from the study of pattern recognition and explores the notion that algorithms can learn from and make predictions on data. And, as they begin to become more ‘intelligent’, these algorithms can overcome program instructions to make highly accurate, data-driven decisions. R, Python & Scala are popular languages to work with these workloads.

Big Data Architecture Backbone: Data Refinement is the Key!

Serious data scientists need to make data refinement their priority and break down the data work into three steps:

• Data Ingestion, or call it Data Collection layer - People use different terminologies for the first layer. However, the main focus of this layer is to choose the right technology depending on Big Data architecture workload and project requirements. If the requirement demands real-time processing we can use Kafka or any other real-time MQ systems mentioned earlier. If the source is just a flat file that is generated a few times a day, go with a simple file transfer protocol. In the end, don't forget money and third-party vendor technology support matters as well.

• Data Enrichment, Transformation, Processing & Refinement - To be instrumentally useful, data must be converted into “answers” to questions. In other words, Big Data must get smaller after passing the second layer. Don't pile up raw data which is not in question as it's going to dramatically slow down your process over a period.

• Data Publish, or Delivery so called the Presentation Layer - Deliver the answers through optimized channels in proper formats and frequency. This layer includes reporting, visualization, data exploration, ad-hoc querying, and export datasets. Visualization through Tableau, QlikView, etc, reporting through BOBJ, SSRS, etc, ad-hoc querying using Hive, Impala, Spark SQL, etc. Further, the choice of technology depends upon end users - different users like administrators, business users, vendors, partners, etc. demand data in different formats.

Data Storage

Hadoop distributed file system is the most commonly used storage framework in Big Data architecture, others are the NoSQL data stores – MongoDB, HBase, Cassandra, etc. One of the salient features of Hadoop storage is its capability to scale, self-manage, and self-heal.

Things to consider while planning storage methodology:

• Type of data (historical or incremental)

• Format of data ( structured, semi-structured, and unstructured)

• The analytical requirement that storage can support (synchronous & asynchronous)

• Compression requirements

• Frequency of incoming data

• Query pattern on the data

• Consumers of the data

Thank you! Hope you enjoyed the blog!

Next: What are Artificial Intelligence, Machine Learning, Deep Learning, Predictive Analytics, and Data Science?

Navigation menu

​1. Apache Spark and Scala Installation

1.1 Spark installation on Windows​

1.2 Spark installation on Mac

2. Getting Familiar with Scala IDE

2.1 Hello World with Scala IDE​

3. Spark data structure basics

3.1 Spark RDD Transformations and Actions Example

4. Spark Shell

4.1 Starting Spark shell with SparkContext example​

5. Reading data files in Spark

5.1 SparkContext Parallelize and read textFile method

5.2 Loading JSON file using Spark Scala

5.3 Loading TEXT file using Spark Scala

5.4 How to convert RDD to dataframe?

6. Writing data files in Spark

​6.1 How to write a Single CSV file in Spark

7. Spark streaming

7.1 Word count example Scala

7.2 Analyzing Twitter Texts

8. Sample Big Data Architecture with Apache Spark

9. What are Artificial Intelligence, Machine Learning, Deep Learning, Predictive Analytics, and Data Science?

10. Spark Interview Questions and Answers