Community Articles
Find and share helpful community-sourced technical articles
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.
Labels (2)

Before completing this tutorial, it is important to understand data lineage.

What is Data Lineage

Data lineage is defined as a data life cycle that conveys data origin and where data moves over time. In Apache Hive, if I create a table (TableA) and then insert data (from another table TableB), the data lineage will display TableA as the target and Table B as the source/origin. These two tables are linked together by a process "insert into Table..", allowing a user to understand the data life cycle. In a Hadoop ecosystem, Apache Atlas contains the data lineage for various systems like Apache Hive, Apache Falcon and Apache Sqoop.

What is Apache Atlas

Apache Atlas is a centralized governance framework that supports the Hadoop ecosystem as a metastore repository. To add metadata to Atlas, libraries called ‘hooks’ are enabled in various systems which automatically capture metadata events in the respective systems and propagate those events to Atlas. (More on Atlas' Architecture).

Prerequisites

  • Download Atlas-Ranger preview VM here

Once the Atlas-Ranger VM is running, you can login through an SSH shell with user = root, password = hadoop

Atlas UI: http://localhost:21000 (use: Data Lineage), user = admin, password = admin

Ambari UI: http://localhost:8080 (use: Hive View), user = admin, password = admin

Step 1 - Login to Ambari and access Hive View

4613-hive-view-ambari.png

Step 2 - Create table brancha (database = default)

create table brancha(full_name string, ssn string, location string);

Step 3 - Create table branchb (database = default)

create table branchb(full_name string, ssn string, location string);

Step 4 - Insert data into both tables

insert into brancha(full_name,ssn,location) values ('ryan', '111-222-333', 'chicago'); 
insert into brancha(full_name,ssn,location) values ('brad', '444-555-666', 'minneapolis'); 
insert into brancha(full_name,ssn,location) values ('rupert', '000-000-000', 'chicago'); 
insert into brancha(full_name,ssn,location) values ('john', '555-111-555', 'boston');
insert into branchb(full_name,ssn,location) values ('jane', '666-777-888', 'dallas'); 
insert into branchb(full_name,ssn,location) values ('andrew', '999-999-999', 'tampa'); 
insert into branchb(full_name,ssn,location) values ('ryan', '111-222-333', 'chicago'); 
insert into branchb(full_name,ssn,location) values ('brad', '444-555-666', 'minneapolis');

(Using Atlas-Ranger preview - execute one insert statement at a time)

Step 5 - In a web browser, access Atlas UI at http://localhost:21000 and search for default.brancha

4616-defaultbranchasearch.png

Step 6 - In the Atlas UI, select the hyperlink under the column name "default.brancha@erietp"

4617-defaultbrancha.png

Step 7 - In the Atlas UI, there should be no lineage for brancha

4618-brancha-lineage.png

Step 8 - Create table branch_intersect (database = default) as a join of brancha and branchb where the ssn is equal

create table branch_intersect as select b1.full_name,b1.ssn,b1.location from brancha b1 inner join branchb b2 ON b1.ssn = b2.ssn;

Step 9 - In the Atlas UI, refresh the browser from Step 7

4619-step7-refresh-browser.png

(orange = current table) You can see source brancha had a process of “create table br...” populating the target branch_intersect table

Step 10 - In the Atlas UI, search for default.branch_intersect

4620-branch-intersect.png

13,543 Views
Comments
Contributor

Hi Ryan, nice demo, seems some of the confusion when you look through the lineage type questions, is where lineage begins. this is a loaded question, but why would lineage not begin with the initial input of data to a table through say through hive view off of ambari, or beeline script, etc. Curious of your thoughts

New Contributor

@Ryan Cicak

Hi,this is the demo that help me well. But when I execeted the command:

insert into brancha(full_name,ssn,location) values ('ryan', '111-222-333', 'chicago'); 

It report error like this:

java.io.FileNotFoundException: File does not exist: hdfs://localhost:9000/usr/local/data-governance/apache-atlas-0.7-incubating-SNAPSHOT/hook/hive/atlas-client-0.7-incubating-SNAPSHOT.ja

The detail of this issue is posted on my another thread:

https://community.hortonworks.com/questions/41898/using-hive-hook-file-does-not-exist-atlas-client-0...

Please check. I hope you can help me. Thank you very much.

Don't have an account?
Coming from Hortonworks? Activate your account here
Version history
Revision #:
2 of 2
Last update:
‎08-17-2019 12:13 PM
Updated by:
 
Contributors
Top Kudoed Authors