spring hadoop 访问hbase入门

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

<!-- Spring hadoop  -->

                   <dependency>

            <groupId>org.apache.hbase</groupId>

            <artifactId>hbase-client</artifactId>

            <version>0.96.1.1-hadoop2</version>

         </dependency>

        <dependency>

            <groupId>org.springframework.data</groupId>

            <artifactId>spring-data-jpa</artifactId>

            <version>1.6.0.RELEASE</version>

        </dependency>

         <dependency>

            <groupId>org.springframework.data</groupId>

            <artifactId>spring-data-hadoop</artifactId>

            <version>2.0.2.RELEASE</version>

         </dependency>

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

  <?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jdbc="http://www.springframework.org/schema/jdbc"

    xmlns:tx="http://www.springframework.org/schema/tx" xmlns:util="http://www.springframework.org/schema/util"

    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:context="http://www.springframework.org/schema/context"

    xmlns:mongo="http://www.springframework.org/schema/data/mongo"

    <span style="color: #ff0000;">xmlns:hdp="http://www.springframework.org/schema/hadoop"</span>

    xmlns:cache="http://www.springframework.org/schema/cache" xmlns:c="http://www.springframework.org/schema/c"

    xmlns:p="http://www.springframework.org/schema/p"

    xsi:schemaLocation=" 

        http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc.xsd

        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd

        http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd

        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd

        http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd

        http://www.springframework.org/schema/data/mongo http://www.springframework.org/schema/data/mongo/spring-mongo.xsd

        <span style="color: #ff0000;">http://www.springframework.org/schema/hadoop http://www.springframework.org/schema/hadoop/spring-hadoop.xsd</span> 

        http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache.xsd

        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

2

3

4

5

6

7

8

9

10

11

Tile t = hbaseTemplate.get("GW_TILES", "0_1_1", new RowMapper<Tile>() {

            @Override

            public Tile mapRow(Result result, int rowNum) throws Exception {

                // TODO Auto-generated method stub

                Tile t = new Tile();

                t.setData(result.getValue("T".getBytes(), "key".getBytes()));

                return t;

            }

        });

2

3

4

5

6

7

8

9

10

11

Tile t = hbaseTemplate.get("GW_TILES", "0_1_1", new RowMapper<Tile>() {

            @Override

            public Tile mapRow(Result result, int rowNum) throws Exception {

                // TODO Auto-generated method stub

                Tile t = new Tile();

                t.setData(result.getValue("T".getBytes(), "key".getBytes()));

                return t;

            }

        });

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

return hbaseTemplate.execute(dataIdentifier, new TableCallback<Boolean>() {

            @Override

            public Boolean doInTable(HTableInterface table) throws Throwable {

                // TODO Auto-generated method stub

                boolean flag = false;

                try{

                Delete delete = new Delete(key.getBytes());

                table.delete(delete);

                flag = true;

                }catch(Exception e){

                    e.printStackTrace();

                }

                return flag;

            }

        });