com.nhncorp.neptune.tabletserver
Class ColumnCollection

java.lang.Object
  com.nhncorp.neptune.tabletserver.ColumnCollection

public class ColumnCollection
extends java.lang.Object

Field Summary

static org.apache.commons.logging.Log

LOG

Constructor Summary

ColumnCollection(NConfiguration conf)

Method Summary

int	addValue(Row.Key rowKey, ColumnValue columnValue, int numOfVersion)
Row.Key	findNearestRowKey(Row.Key rowKey) MEAT, ROOT tablet인 경우만 사용된다.
ColumnValue[]	get(Row.Key rowKey)
ColumnValue	get(Row.Key rowKey, Cell.Key columnKey)
ColumnValue[][]	getAllVersion(Row.Key rowKey, Cell.Key columnKey)
int	getRowCount()
ValueCollection	getValueCollection(Row.Key rowKey, Cell.Key columnKey)
static void	main(java.lang.String[] args)
void	print()
void	print(Row.Key rowKey)
TabletMapFile	saveToDisk(TabletInfo tabletInfo, java.lang.String columnName, java.lang.String fileId, int numOfVersion) 데이터를 임시 디렉토리에 저장한다.
TabletMapFile	saveToLocalDisk(NeptuneFileSystem fs, TabletInfo tabletInfo, java.lang.String columnName, java.lang.String fileId, java.lang.String uploadAcitonId, int numOfVersion) BatchUpload를 위해 임시로 로컬 파일시스템에 저장시킨다.
TabletMapFile[]	splitAndSaveToDisk(TabletInfo tabletInfo, Row.Key midRowKey, TabletInfo[] splitedTabletInfos, java.lang.String columnName, java.lang.String fileId, int numOfVersion)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.apache.commons.logging.Log LOG

Constructor Detail

ColumnCollection

public ColumnCollection(NConfiguration conf)

Method Detail

addValue

public int addValue(Row.Key rowKey,
                    ColumnValue columnValue,
                    int numOfVersion)
             throws java.io.IOException

Throws:

java.io.IOException

print

public void print()

get

public ColumnValue get(Row.Key rowKey,
                       Cell.Key columnKey)

getValueCollection

public ValueCollection getValueCollection(Row.Key rowKey,
                                          Cell.Key columnKey)

get

public ColumnValue[] get(Row.Key rowKey)

getAllVersion

public ColumnValue[][] getAllVersion(Row.Key rowKey,
                                     Cell.Key columnKey)

print

public void print(Row.Key rowKey)

saveToDisk

public TabletMapFile saveToDisk(TabletInfo tabletInfo,
                                java.lang.String columnName,
                                java.lang.String fileId,
                                int numOfVersion)
                         throws java.io.IOException

데이터를 임시 디렉토리에 저장한다.

Parameters:

tabletInfo -

columnName -

Returns:

Throws:

java.io.IOException

saveToLocalDisk

public TabletMapFile saveToLocalDisk(NeptuneFileSystem fs,
                                     TabletInfo tabletInfo,
                                     java.lang.String columnName,
                                     java.lang.String fileId,
                                     java.lang.String uploadAcitonId,
                                     int numOfVersion)
                              throws java.io.IOException

BatchUpload를 위해 임시로 로컬 파일시스템에 저장시킨다.

Parameters:

fs -

tabletInfo -

columnName -

fileId -

Returns:

Throws:

java.io.IOException

splitAndSaveToDisk

public TabletMapFile[] splitAndSaveToDisk(TabletInfo tabletInfo,
                                          Row.Key midRowKey,
                                          TabletInfo[] splitedTabletInfos,
                                          java.lang.String columnName,
                                          java.lang.String fileId,
                                          int numOfVersion)
                                   throws java.io.IOException

Throws:

java.io.IOException

findNearestRowKey

public Row.Key findNearestRowKey(Row.Key rowKey)

MEAT, ROOT tablet인 경우만 사용된다. 하나의 rowkey에 컬럼의 데이터는 하나만 저장되고, 삭제되지 않은 데이터중 가장 근접한 값을 반환한다.

Parameters:

rowKey -

Returns:

getRowCount

public int getRowCount()

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

Throws:

java.lang.Exception