We are going to give a quick overview of how stored views and materialized views can be created in Databricks. For this demo, we will create our two gold layer entities. We will start by creating a view in the gold layer against our silver table customers_orders. Our view will simply contain some aggregations for … Read more
We are going to see how to use CDF data to propagate changes to downstream tables. For this demo, we will create a new silver table called customers_orders by joining two streams: The orders table with the CDF data of the customers table. We will start by creating a function to upsert ranked updates into … Read more
Change Data Capture or CDC refers to the process of identifying and capturing changes made to data in the data source and then delivering those changes to the target. Those changes could be obviously new records to be inserted from the source to the target. Updated records in the source that need to be reflected … Read more
Learning Objectives Change Data Feed or CDF is a new feature built into Delta Lake that allows to automatically generate CDC feeds about Delta Lake tables. CDF records row-level changes for all the data written into a delta table. These include the raw data along with metadata indicating whether the specified row was inserted, deleted … Read more
Find the second highest salary from the Employee table. Find duplicate records in a table. Retrieve employees who earn more than their manager. Count employees in each department having more than 5 employees. Find employees who joined in the last 6 months. Get departments with no employees. Write a query to find the median salary. … Read more
Data Pipeline Data pipeline: Mapping data flow from collection to analysis for organizational insights. Source, process, deliver for analytics efficiency. Database vs Schema vs Table Database: Organized collection of related data, like a file cabinet for storing information. Schema: Blueprint defining structure and organization within a database. Table: Grid-like structure within a schema, where data … Read more
Introduction Slowly Changing Dimensions, or SCD is a data management concept that determines how tables handle data which change over time. For example, whether you want to overwrite values in the table or maybe retain their history. This can be determined by the SCD type to implement. There are three types of SCD which are … Read more
In this notebook, we are going to parse raw data from a single topic in our multiplexer bronze table. As you can see, in our architecture diagram, we will create the orders silver table. Let us start by copying our dataset files. Before starting, we need to cast our Kafka binary fields as strings. Here … Read more
Learning Objectives You will understand the available ingestion models in the bronze layers and the difference between them, and you will learn how the ingested data will be promoted to the silver layer. When setting up ingestion into the bronze layer, we need to decide how input datasets should be mapped to the bronze tables. … Read more
6 broad categories related to the For Databricks Certified Data Engineer Professional exam topics, which are: Having the Data Engineer Associate certification from Databricks is not a prerequisite to appear for the Professional-level certification exam. However, this exam assumes that you have the skills of a data engineer associate on Databricks platform. The source code … Read more