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)
|
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()