Skip to content

Commit f7ef44e

Browse files
committed
Update spark-hbase-demo1.md
1 parent 036ad34 commit f7ef44e

File tree

1 file changed

+10
-3
lines changed

1 file changed

+10
-3
lines changed

examples/spark-hbase-demo1.md

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,8 @@
1-
## create spark sql table to non-exist hbase (support multiple columns mapping to hbase rowkey)
1+
## Create and query SparkSQL table map to HBase (support multiple columns mapping to hbase rowkey)
22
(1)TableName :
33
spark : spark_teacher_3key
44
hbase : hbase_ teacher_3key
5+
56
(2)Fields :
67
[grade,int]
78
[class,int]
@@ -12,12 +13,17 @@
1213
keyCols : grade,class,subject
1314

1415
(3)Create table:
15-
CREATE TABLE teacher1k(grade int, class int, subject string, teacher_name string, teacher_age int, PRIMARY KEY (grade, class, subject)) MAPPED BY (hbase1k, COLS=[teacher_name=teacher.name, teacher_age=teacher.age]);
16+
```
17+
CREATE TABLE teacher1k(grade int, class int, subject string, teacher_name string, teacher_age int, PRIMARY KEY (grade, class, subject)) MAPPED BY (hbase1k, COLS=[teacher_name=teacher.name, teacher_age=teacher.age]);
18+
```
1619

1720
(4)Load data :
18-
LOAD DATA INPATH './examples/teacher1k.csv' INTO TABLE teacher1k FIELDS TERMINATED BY "," ;
21+
```
22+
LOAD DATA INPATH './examples/teacher1k.csv' INTO TABLE teacher1k FIELDS TERMINATED BY "," ;
23+
```
1924

2025
(5) Query :
26+
```
2127
// test where
2228
(1) select teacher_name,teacher_age from teacher1k where teacher_age > 25;
2329
@@ -32,3 +38,4 @@
3238
3339
//test join
3440
(5) select t1.teacher_name, t2.subject, t1.teacher_age from (select teacher_name, teacher_age from teacher1k where teacher_age >=26 ) t1 join (select teacher_name, subject from teacher1k where teacher_name like 'teacher_2_3%')t2 on t1.teacher_name=t2.teacher_name
41+
```

0 commit comments

Comments
 (0)