Learn Big Data: The Hadoop Ecosystem Masterclass

The 3 (or 4) V's of Big Data explained

What is Big Data? Some examples of companies using Big Data, like Spotify, Amazon, Google, and Tesla

What can we do with Big Data? Data Science explained.

How to build a Big Data System? What is Hadoop?

Hadoop Distributions: a comparison between Apache Hadoop, Hortonworks Data Platform, Cloudera, and MapR

In 2025, Ambari 3 was released, making it easier to provision a Hadoop cluster. This demo shows how to provision a Hadoop cluster using docker and Ambari 3, replacing the HDP Vagrant/Sandbox install.

How to install Hadoop? You can install Hadoop using vagrant with Virtualbox / VMWare, or on the Cloud using AWS. Hortonworks also provides a Sandbox.

This is a demo of how to install and use the Hortonworks Sandbox. An alternative to the full installation using Ambari if you have a machine that doesn't have a lot of memory available. You can also use both in conjunction. 

A walkthrough of how to install the Hortonworks Data Platform (HDP) on your Laptop or Desktop

A walkthrough of how to install the Hortonworks Data Platform (HDP) on your Laptop or Desktop (Part II)

An introduction to HDFS, The Hadoop Distributed Filesystem

Communications between the DataNode and the NameNode explained

An introduction to HDFS using hadoop fs put. I'm also showing how a files gets divided in blocks and where those blocks are stored.

An introduction to downloading, uploading and listing files. This time I'm using the Ambari HDFS Viewer and the NameNode UI. I also show what configuration changes are necessary to make this work.

MapReduce WordCount, step by step explained

A demo of MapReduce WordCount on our HDP cluster

In HDFS, files are divided in blocks and stored on the DataNodes. In this lecture we're going to see what happens when we're reading lines from files that potentially span over multiple blocks.

Introducing Yarn, and concepts like the ResourceManager, the scheduler, the applicationsManager, the NodeManager, and the Application Master. I explain how an application is executed and the consequences when a node crashes.

A demo of an application executed using yarn jar. I provide an overview of Ambari Yarn metrics and the ResourceManager UI

Ambari also exposes a REST API. Commands can be executed directly to this API. Ambari also lets you do unattended install using Ambari Blueprints

A demo showing you the Ambari API and how to work with blueprints

An introduction to ETL processing in Hadoop. MapReduce, Pig, and Spark are suitable to do batch processing. Hive is more suitable for data exploration.

An introduction to Pig and Pig Latin.

This demo shows how to install pig and tez using Ambari on the Hortonworks Data Platform

In this demo I will show you basic pig commands to load, dump and store data. I'll also show you an example how to filter data.

More Pig commands in this final part of the pig demo. I'll go over commands like GROUP BY, FOREACH ... GENERATE and COUNT()

An introduction to Apache Spark. This lecture explains the differences between the spark-submit using local mode, yarn-cluster and yarn-client.

An introduction to WordCount in Spark using Python (pyspark)

Spark installation using Ambari and a demo of the Spark Wordcount using the pyspark shell.

This lectures gives an introduction to Resilient Distributed Datasets (RDDs). This abstraction allows you to do transformations and actions in Spark. I give an example using filter RDDs, and explain how shuffle RDDs impact disk and network IO

A demo of RDD transformations and actions in Spark

An overview of the most common RDD actions and transformations

An overview of what Spark MLLib (Machine Learning Library) can do. I explain a Recommendation Engine example, and a Clustering Example (K-Means / DBScan)

An introduction to SQL on Hadoop using Hive, enabling data warehouse capabilities. This lecture provides an architecture overview and an overview of the hive CLI and beeline using JDBC.

An overview of Hive Queries: creating tables, creating databases, inserting data, and selecting data. This lecture also shows where the hive data is stored in HDFS.

A demo that shows the installation of Hiveserver2 and the clients. Afterwards I show you a few example queries using a JDBC beeline connection.

Optimizing hive can't be done using indexes. This lecture explains how queries in hive should be optimized, using partitions and buckets. This lecture also handles User Defined Functions (UDFs) and Serialization / Deserialization

The Stinger initiative brings optimizations to Spark. Query time has lowered significantly over the years. This lecture explains you the details.

You can also use Hive in Spark using the Spark SQLContext.

All the lectures up until now were batch oriented. From now on we're going to discuss Realtime processing technologies like Kafka, Storm, Spark Streaming, and HBase / Phoenix.

An introduction to Kafka and its terminology like Producers, Consumers, Topics and Partitions.

An explanation of Kafka Topics covering Leader partitions, Follower partitions, and how writes are sent to the partitions. Also covers the Consumer groups to show the difference between publish-subscribe (pubsub) mechanism and queuing

Kafka guarantees at-least-once message delivery, but can also be configured for at-most-once. Log Compaction is a technique that Kafka provides to have a full dataset maintained in the commit log. This lecture shows an example of a customer dataset fully kept in Kafka and explains Log Tail, Cleaner Point and Log Head and how it impacts consumers.

A few example use cases of Kafka

The installation of Kafka on the Hortonworks Data Platform and a demo of a producer - consumer example.

This lecture provides an introduction to Storm, a realtime computing system. The architecture overview explains components like Nimbus, Zookeeper, and the Supervisor

This lecture explains what Storm topologies are. I talk about streams, tuples, spouts, and bolts.

A demo of a Storm Topology ingesting data from Kafka and doing computation on the data.

Message Delivery explained:

• At most once delivery
• At least once delivery
• Exactly once delivery

This lecture also explains the Storm's reliability API (Anchoring and Acking) and the performance impact of acking.

An introduction to the Trident API, an alternative interface for Storm that supports exactly-once processing of messages.

Spark streaming is an alternative to Storm that gained a lot of popularity in the last few years. It allows you to reuse the code you wrote in batch and use it for stream processing.

Spark Streaming generates DStreams, micro-batches of RDDs. This lecture explains the Spark Streaming Architecture

This lecture explains possible receivers, like Kafka. It also shows a WordCount streaming example, where data is ingested from Kafka and processed using WordCount in Spark Streaming

This demo shows the Kafka-spark-streaming example.

In the previous lecture we did a WordCount using Spark Streaming, but our example was stateless. In this lecture I'm adding state, using UpdateStateByKey to keep state and checkpointing to save the data to HDFS.

A demo of a stateful spark streaming application. Performs a global WordCount from a topic from Kafka. Does checkpointing in HDFS.

More Spark Streaming Features, like Windowing and streaming algorithms