際際滷

際際滷Share a Scribd company logo
Radu Pastia - Couchdoop - Connecting Hadoop with Couchbase
pas$aro.wordpress.com 
@rpas$a
Radu Pastia - Couchdoop - Connecting Hadoop with Couchbase
Building a connector  The Wrong Way 
Mapper 
Reducer
Radu Pastia - Couchdoop - Connecting Hadoop with Couchbase
Building a connector  The Right Way 
Mapper 
Par$$oner 
Reducer 
Input 
Format 
Input 
Split 
Record 
Reader 
Output 
Format 
Record 
Writer
Radu Pastia - Couchdoop - Connecting Hadoop with Couchbase
Radu Pastia - Couchdoop - Connecting Hadoop with Couchbase
Radu Pastia - Couchdoop - Connecting Hadoop with Couchbase
The InputFormat: From Input to Mapper 
--range 2014-09-01;2014-09-20 
--number_of_mappers 4 
2014-足09-足01 
2014-足09-足02 
2014-足09-足03 
2014-足09-足04 
2014-足09-足05 
 
 
 
2014-足09-足06 
2014-足09-足20 
Input Split 1 
2014-足09-足01 
2014-足09-足02 
... 
2014-足09-足05 
Record Reader 1 
(2014-足09-足01-足A; 
record 
A) 
(2014-足09-足01-足B; 
record 
B) 
(2014-足09-足01-足; 
record 
) 
(2014-足09-足02-足A; 
record 
A) 
(2014-足09-足02-足B; 
record 
B) 
(2014-足09-足02-足; 
record 
) 
(2014-足09-足05-足A; 
record 
A) 
(2014-足09-足05-足B; 
record 
B) 
(2014-足09-足05-足; 
record 
) 
Mapper
Radu Pastia - Couchdoop - Connecting Hadoop with Couchbase
Radu Pastia - Couchdoop - Connecting Hadoop with Couchbase
Radu Pastia - Couchdoop - Connecting Hadoop with Couchbase
Radu Pastia - Couchdoop - Connecting Hadoop with Couchbase
Radu Pastia - Couchdoop - Connecting Hadoop with Couchbase
The InputFormat: From Input to Mapper 
--range 2014-09-01;2014-09-20 
--number_of_mappers 4 
2014-足09-足01 
2014-足09-足02 
2014-足09-足03 
2014-足09-足04 
2014-足09-足05 
 
 
 
2014-足09-足06 
2014-足09-足20 
Input Split 1 
2014-足09-足01 
2014-足09-足02 
... 
2014-足09-足05 
Record Reader 1 
(2014-足09-足01-足A; 
record 
A) 
(2014-足09-足01-足B; 
record 
B) 
(2014-足09-足01-足; 
record 
) 
(2014-足09-足02-足A; 
record 
A) 
(2014-足09-足02-足B; 
record 
B) 
(2014-足09-足02-足; 
record 
) 
(2014-足09-足05-足A; 
record 
A) 
(2014-足09-足05-足B; 
record 
B) 
(2014-足09-足05-足; 
record 
) 
Mapper
Radu Pastia - Couchdoop - Connecting Hadoop with Couchbase
Radu Pastia - Couchdoop - Connecting Hadoop with Couchbase
Radu Pastia - Couchdoop - Connecting Hadoop with Couchbase
Radu Pastia - Couchdoop - Connecting Hadoop with Couchbase

More Related Content

Radu Pastia - Couchdoop - Connecting Hadoop with Couchbase

  • 4. Building a connector The Wrong Way Mapper Reducer
  • 6. Building a connector The Right Way Mapper Par$$oner Reducer Input Format Input Split Record Reader Output Format Record Writer
  • 10. The InputFormat: From Input to Mapper --range 2014-09-01;2014-09-20 --number_of_mappers 4 2014-足09-足01 2014-足09-足02 2014-足09-足03 2014-足09-足04 2014-足09-足05 2014-足09-足06 2014-足09-足20 Input Split 1 2014-足09-足01 2014-足09-足02 ... 2014-足09-足05 Record Reader 1 (2014-足09-足01-足A; record A) (2014-足09-足01-足B; record B) (2014-足09-足01-足; record ) (2014-足09-足02-足A; record A) (2014-足09-足02-足B; record B) (2014-足09-足02-足; record ) (2014-足09-足05-足A; record A) (2014-足09-足05-足B; record B) (2014-足09-足05-足; record ) Mapper
  • 16. The InputFormat: From Input to Mapper --range 2014-09-01;2014-09-20 --number_of_mappers 4 2014-足09-足01 2014-足09-足02 2014-足09-足03 2014-足09-足04 2014-足09-足05 2014-足09-足06 2014-足09-足20 Input Split 1 2014-足09-足01 2014-足09-足02 ... 2014-足09-足05 Record Reader 1 (2014-足09-足01-足A; record A) (2014-足09-足01-足B; record B) (2014-足09-足01-足; record ) (2014-足09-足02-足A; record A) (2014-足09-足02-足B; record B) (2014-足09-足02-足; record ) (2014-足09-足05-足A; record A) (2014-足09-足05-足B; record B) (2014-足09-足05-足; record ) Mapper