com.poscoict.glueframework.dao.hbase

Class GlueHbaseDao

java.lang.Object

com.poscoict.glueframework.dao.hbase.GlueHbaseDao

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean

public class GlueHbaseDao
extends Object
implements org.springframework.beans.factory.InitializingBean

Hbase와 연동하기 위한 Dao Class

Constructor Summary

Constructors

Constructor and Description
GlueHbaseDao()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
String	delete(String tableName, String row_id) 해당 데이터를 삭제한다.
List<Map<String,Object>>	find(String tableName) Default 컬럼 패밀리에 해당하는 전체 데이터를 조회한다.
List<Map<String,Object>>	find(String tableName, String family) 전체 데이터를 조회한다.
List<Map<String,Object>>	find(String tableName, String family, org.apache.hadoop.hbase.client.Scan scan) 해당 데이터를 조회한다.
Map<String,Object>	save(String tableName, Map<String,Object> params) 해당 데이터를 Default 컬럼 패밀리에 저장한다.
Map<String,Object>	save(String tableName, String family, Map<String,Object> params) 해당 데이터를 저장한다.
void	setDefaultCf(String defaultCf)
void	setHbaseTemplate(org.springframework.data.hadoop.hbase.HbaseTemplate hbaseTemplate)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GlueHbaseDao

public GlueHbaseDao()

Method Detail

setHbaseTemplate

public void setHbaseTemplate(org.springframework.data.hadoop.hbase.HbaseTemplate hbaseTemplate)

setDefaultCf

public void setDefaultCf(String defaultCf)

find

public List<Map<String,Object>> find(String tableName)

Default 컬럼 패밀리에 해당하는 전체 데이터를 조회한다.

Parameters:

String - tableName Hbase에서 조회 할 데이터의 테이블 명

find

public List<Map<String,Object>> find(String tableName,
                                     String family)

전체 데이터를 조회한다.

Parameters:

String - tableName Hbase에서 조회 할 데이터의 테이블 명

String - family Hbase에서 조회 할 데이터의 컬럼 패밀리

find

public List<Map<String,Object>> find(String tableName,
                                     String family,
                                     org.apache.hadoop.hbase.client.Scan scan)

해당 데이터를 조회한다.

Parameters:

String - tableName Hbase에서 조회 할 데이터의 테이블 명

String - family Hbase에서 조회 할 데이터의 컬럼 패밀리

Scan - scan Hbase에서 조회 할 데이터의 조회 조건이 정의된 Scan 객체

save

public Map<String,Object> save(String tableName,
                               Map<String,Object> params)

해당 데이터를 Default 컬럼 패밀리에 저장한다.

Parameters:

String - tableName Hbase에 저장할 데이터의 테이블 명

Map - params Hbase에 저장할 데이터

save

public Map<String,Object> save(String tableName,
                               String family,
                               Map<String,Object> params)

해당 데이터를 저장한다.

Parameters:

String - tableName Hbase에 저장할 데이터의 테이블 명

String - family Hbase에 저장할 데이터의 컬럼 패밀리

Map - params Hbase에 저장할 데이터

delete

public String delete(String tableName,
                     String row_id)

해당 데이터를 삭제한다.

Parameters:

String - row_id Hbase에서 삭제할 데이터의 Key

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception