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

GlueHbaseDao()

Method Summary

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