com.nhncorp.neptune.tabletserver
Interface MemorySSTableIF

All Superinterfaces:

ProxyObject

All Known Implementing Classes:

MemorySSTable

public interface MemorySSTableIF
extends ProxyObject

Method Summary

void	cancelCompaction(java.lang.String fileId)
void	clearAllMemory()
void	clearChangeLogOf(java.lang.String tabletName)
void	clearCompactingColumnCollections()
void	commit(TxId txId, ChangeLog[] changeLogList, boolean saveLog)
void	endChangeLogMinorCompaction()
Row.Key	findClosest(Row.Key rowKey, java.lang.String string)
Row.Key	findMidRowKeyForSplit() Split 처리를 위해 가운데의 rowkey 값을 가져온다.
ColumnValue[]	getAllMemoryValues(java.lang.String columnName) ROOT, META 테이블 검증용으로 사용된다.
java.util.SortedSet<Row.Key>	getAllRowKeys() MemorySSTable에 있는 rowkey의 목록을 반환한다.
ChangeLogFileSystemIF	getChangeLogFileSystem()
java.util.Map<java.lang.String,ColumnCollection>	getColumnCollections()
java.util.Map<java.lang.String,ColumnCollection>	getCompactingColumnCollections()
int[]	getDataCount()
Scanner	getScanner(java.lang.String columnName, Row.Key startRowKey, Row.Key endRowKey, CellFilter columnFilter)
Searchable	getSearcher(Row.Key rowKey, java.lang.String columnName, Cell.Key cellKey)
int	getTabletSize()
boolean	hasValue(Row.Key rowKey, java.lang.String columnName)
void	init(TabletServerIF tabletServer, NConfiguration conf, TabletInfo tabletInfo, int nemOfVersion)
void	initMemoryForCompaction()
boolean	isDeleted(Row.Key rowKey, java.lang.String columnName)
boolean	isEmpty()
boolean	loadFromChangeLog()
void	obtainWriteLock()
void	print()
void	releaseWriteLock()
java.util.Map<java.lang.String,TabletMapFile>	saveToDisk(TabletInfo tabletInfo, java.lang.String fileId)
void	setCompacting(boolean compacting)
java.util.Map<java.lang.String,TabletMapFile[]>	splitAndSave(Row.Key midRowKey, TabletInfo[] splitedTabletInfos)

Methods inherited from interface com.nhncorp.neptune.common.aop.ProxyObject

getTestHandlerKey

Method Detail

getSearcher

Searchable getSearcher(Row.Key rowKey,
                       java.lang.String columnName,
                       Cell.Key cellKey)
                       throws java.io.IOException

Throws:

java.io.IOException

clearCompactingColumnCollections

void clearCompactingColumnCollections()

saveToDisk

java.util.Map<java.lang.String,TabletMapFile> saveToDisk(TabletInfo tabletInfo,
                                                         java.lang.String fileId)
                                                         throws java.io.IOException

Throws:

java.io.IOException

init

void init(TabletServerIF tabletServer,
          NConfiguration conf,
          TabletInfo tabletInfo,
          int nemOfVersion)
          throws java.io.IOException

Throws:

java.io.IOException

print

void print()

loadFromChangeLog

boolean loadFromChangeLog()
                          throws java.io.IOException

Throws:

java.io.IOException

findClosest

Row.Key findClosest(Row.Key rowKey,
                    java.lang.String string)
                    throws java.io.IOException

Throws:

java.io.IOException

getTabletSize

int getTabletSize()

commit

void commit(TxId txId,
            ChangeLog[] changeLogList,
            boolean saveLog)
            throws java.io.IOException

Throws:

java.io.IOException

getScanner

Scanner getScanner(java.lang.String columnName,
                   Row.Key startRowKey,
                   Row.Key endRowKey,
                   CellFilter columnFilter)
                   throws java.io.IOException

Throws:

java.io.IOException

isEmpty

boolean isEmpty()

initMemoryForCompaction

void initMemoryForCompaction()
                             throws java.io.IOException

Throws:

java.io.IOException

cancelCompaction

void cancelCompaction(java.lang.String fileId)

getChangeLogFileSystem

ChangeLogFileSystemIF getChangeLogFileSystem()

getColumnCollections

java.util.Map<java.lang.String,ColumnCollection> getColumnCollections()

endChangeLogMinorCompaction

void endChangeLogMinorCompaction()
                                 throws java.io.IOException

Throws:

java.io.IOException

getCompactingColumnCollections

java.util.Map<java.lang.String,ColumnCollection> getCompactingColumnCollections()

setCompacting

void setCompacting(boolean compacting)

splitAndSave

java.util.Map<java.lang.String,TabletMapFile[]> splitAndSave(Row.Key midRowKey,
                                                             TabletInfo[] splitedTabletInfos)
                                                             throws java.io.IOException

Throws:

java.io.IOException

getDataCount

int[] getDataCount()

obtainWriteLock

void obtainWriteLock()

releaseWriteLock

void releaseWriteLock()

isDeleted

boolean isDeleted(Row.Key rowKey,
                  java.lang.String columnName)
                  throws java.io.IOException

Throws:

java.io.IOException

hasValue

boolean hasValue(Row.Key rowKey,
                 java.lang.String columnName)
                 throws java.io.IOException

Throws:

java.io.IOException

getAllMemoryValues

ColumnValue[] getAllMemoryValues(java.lang.String columnName)

ROOT, META 테이블 검증용으로 사용된다. 해당 메소드가 호출되는 경우에는 Split 등의 작업이 lock이 걸리기 때문에 메모리의 값에 대한 변경이 거의 없다.

Parameters:

columnName -

Returns:

getAllRowKeys

java.util.SortedSet<Row.Key> getAllRowKeys()

MemorySSTable에 있는 rowkey의 목록을 반환한다.

Parameters:

columnName -

Returns:

clearChangeLogOf

void clearChangeLogOf(java.lang.String tabletName)

clearAllMemory

void clearAllMemory()

findMidRowKeyForSplit

Row.Key findMidRowKeyForSplit()
                              throws java.io.IOException

Split 처리를 위해 가운데의 rowkey 값을 가져온다.

Throws:

java.io.IOException