com.nhncorp.neptune.tabletserver
Interface DiskSSTableIF

All Superinterfaces:
ProxyObject
All Known Implementing Classes:
DiskSSTable

public interface DiskSSTableIF
extends ProxyObject


Method Summary
 void addMergedFiles(java.util.Map<java.lang.String,java.util.List<TabletMapFile>> targetMapFiles, java.util.Map<java.lang.String,TabletMapFile> mergedMapFiles)
           
 void addTabletMapFile(java.lang.String columnName, TabletMapFile mapFile)
           
 void cancelCompaction(java.lang.String fileId)
           
 void clearAllMemory()
           
 Row.Key findClosest(Row.Key rowKey, MemorySSTableIF memorySSTable, java.lang.String columnName)
           
 Row.Key findMidRowKeyForSplit()
           
 int[] getMapFileCount()
           
 java.util.SortedSet<MapFileIndexRecord> getMapFileIndex()
           
 long[] getMapFileIndexSize()
           
 long getMapFileMemorySize()
           
 java.util.Map<java.lang.String,java.util.List<TabletMapFile>> getMapFiles()
           
 int[] getMapFileSize()
           
 int getMaxMapFileCount()
           
 java.util.List<Searchable> getSearchers(Row.Key rowKey, java.lang.String columnName, Cell.Key columnKey)
           
 boolean hasValue(Row.Key rowKey, java.lang.String columnName)
           
 void init(TabletServerIF tabletServer, DiskSSTableIF proxyObject, NConfiguration conf, TabletInfo tabletInfo, int numOfVersion)
           
 boolean isEmpty()
           
 void load()
           
 void majorCompaction()
           
 java.util.Map<java.lang.String,TabletMapFile> merge(java.util.Map<java.lang.String,java.util.List<TabletMapFile>> targetMapFiles, java.lang.String fileId)
           
 TabletMapFile mergeMapFiles(java.lang.String fileId, java.lang.String columnName, java.util.List<TabletMapFile> mergeMapFiles)
           
 void moveMajorTempToTablet(java.lang.String columnName, TabletMapFile tabletMapFile)
           
 void moveMergedFile(java.util.Map<java.lang.String,TabletMapFile> mergedMapFiles)
           
 void moveTempToTablet(boolean deleteParent)
           
 void removeTabletMapFile(java.lang.String columnName, TabletMapFile mapFile)
           
 DiskSSTableIF[] split(Row.Key midRowaKey, TabletInfo[] splitedTabletInfos)
           
 void splitMapFile(Row.Key midRowKey, TabletInfo[] createdTablets, DiskSSTableIF[] createdDiskSSTables, java.lang.String columnName, TabletMapFile columnMapFile, java.lang.String fileId)
           
 long sumMapFileSize()
           
 void truncateColumn(java.lang.String columnName)
           
 
Methods inherited from interface com.nhncorp.neptune.common.aop.ProxyObject
getTestHandlerKey
 

Method Detail

getSearchers

java.util.List<Searchable> getSearchers(Row.Key rowKey,
                                        java.lang.String columnName,
                                        Cell.Key columnKey)
                                        throws java.io.IOException
Throws:
java.io.IOException

load

void load()
          throws java.io.IOException
Throws:
java.io.IOException

findClosest

Row.Key findClosest(Row.Key rowKey,
                    MemorySSTableIF memorySSTable,
                    java.lang.String columnName)
                    throws java.io.IOException
Throws:
java.io.IOException

getMaxMapFileCount

int getMaxMapFileCount()

sumMapFileSize

long sumMapFileSize()
                    throws java.io.IOException
Throws:
java.io.IOException

getMapFiles

java.util.Map<java.lang.String,java.util.List<TabletMapFile>> getMapFiles()

isEmpty

boolean isEmpty()

majorCompaction

void majorCompaction()
                     throws java.io.IOException
Throws:
java.io.IOException

addTabletMapFile

void addTabletMapFile(java.lang.String columnName,
                      TabletMapFile mapFile)
                      throws java.io.IOException
Throws:
java.io.IOException

removeTabletMapFile

void removeTabletMapFile(java.lang.String columnName,
                         TabletMapFile mapFile)
                         throws java.io.IOException
Throws:
java.io.IOException

cancelCompaction

void cancelCompaction(java.lang.String fileId)
                      throws java.io.IOException
Throws:
java.io.IOException

findMidRowKeyForSplit

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

split

DiskSSTableIF[] split(Row.Key midRowaKey,
                      TabletInfo[] splitedTabletInfos)
                      throws java.io.IOException
Throws:
java.io.IOException

init

void init(TabletServerIF tabletServer,
          DiskSSTableIF proxyObject,
          NConfiguration conf,
          TabletInfo tabletInfo,
          int numOfVersion)

moveTempToTablet

void moveTempToTablet(boolean deleteParent)
                      throws java.io.IOException
Throws:
java.io.IOException

mergeMapFiles

TabletMapFile mergeMapFiles(java.lang.String fileId,
                            java.lang.String columnName,
                            java.util.List<TabletMapFile> mergeMapFiles)
                            throws java.io.IOException
Throws:
java.io.IOException

moveMajorTempToTablet

void moveMajorTempToTablet(java.lang.String columnName,
                           TabletMapFile tabletMapFile)
                           throws java.io.IOException
Throws:
java.io.IOException

splitMapFile

void splitMapFile(Row.Key midRowKey,
                  TabletInfo[] createdTablets,
                  DiskSSTableIF[] createdDiskSSTables,
                  java.lang.String columnName,
                  TabletMapFile columnMapFile,
                  java.lang.String fileId)
                  throws java.io.IOException
Throws:
java.io.IOException

getMapFileCount

int[] getMapFileCount()

getMapFileSize

int[] getMapFileSize()
                     throws java.io.IOException
Throws:
java.io.IOException

getMapFileMemorySize

long getMapFileMemorySize()
                          throws java.io.IOException
Throws:
java.io.IOException

truncateColumn

void truncateColumn(java.lang.String columnName)
                    throws java.io.IOException
Throws:
java.io.IOException

getMapFileIndexSize

long[] getMapFileIndexSize()
                           throws java.io.IOException
Throws:
java.io.IOException

merge

java.util.Map<java.lang.String,TabletMapFile> merge(java.util.Map<java.lang.String,java.util.List<TabletMapFile>> targetMapFiles,
                                                    java.lang.String fileId)
                                                    throws java.io.IOException
Throws:
java.io.IOException

moveMergedFile

void moveMergedFile(java.util.Map<java.lang.String,TabletMapFile> mergedMapFiles)
                    throws java.io.IOException
Throws:
java.io.IOException

addMergedFiles

void addMergedFiles(java.util.Map<java.lang.String,java.util.List<TabletMapFile>> targetMapFiles,
                    java.util.Map<java.lang.String,TabletMapFile> mergedMapFiles)
                    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

getMapFileIndex

java.util.SortedSet<MapFileIndexRecord> getMapFileIndex()

clearAllMemory

void clearAllMemory()