com.nhncorp.neptune.tabletserver
Class TabletMapFile

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

public class TabletMapFile
extends java.lang.Object

Field Summary

static java.lang.String	DATA_FILE
static java.lang.String	IDX_FILE
static org.apache.commons.logging.Log	LOG

Constructor Summary

TabletMapFile(NConfiguration conf, NeptuneFileSystem fs, TabletInfo tabletInfo, java.lang.String columnName, java.lang.String fileId, GPath filePath, int numOfVersion)

TabletMapFile(NConfiguration conf, TabletInfo tabletInfo, java.lang.String columnName, java.lang.String fileId, int numOfVersion)

Method Summary

static void	copyColumnValue(MapFileColumnValue mapFileColumnValue, ColumnValue columnValue)
boolean	delete()
boolean	equals(java.lang.Object obj)
MapFileIndexRecord	findNearest(Row.Key targetRowKey, Cell.Key cellKey)
java.lang.String	getColumnName()
long	getDataFileSize()
java.lang.String	getFileId()
GPath	getFilePath()
NeptuneFileSystem	getFileSystem()
long	getIndexMemorySize()
java.util.SortedSet<MapFileIndexRecord>	getMapFileIndexRecords()
com.nhncorp.neptune.tabletserver.TabletMapFile.MapFileReader	getMapFileReader()
com.nhncorp.neptune.tabletserver.TabletMapFile.MapFileReader	getMapFileReader(Row.Key startRowKey, Row.Key endRowKey, CellFilter cellFilter)
com.nhncorp.neptune.tabletserver.TabletMapFile.MapFileWriter	getMapFileWriter()
TabletInfo	getTabletInfo()
boolean	hasValue(Row.Key rowKey)
boolean	loadIndex()
static void	main(java.lang.String[] args)
void	moveTo(GPath targetPath, boolean deleteParent)
java.util.List<ColumnValue>	scan(Row.Key rowKey)
ValueCollection	scan(Row.Key rowKey, Cell.Key columnKey)
java.util.SortedSet<ColumnValue>	scanClosestColumnValues(Row.Key rowKey, MemorySSTableIF memorySSTable)
java.lang.String	toString()

Methods inherited from class java.lang.Object

getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

LOG

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

DATA_FILE

public static final java.lang.String DATA_FILE

See Also:

Constant Field Values

IDX_FILE

public static final java.lang.String IDX_FILE

See Also:

Constant Field Values

Constructor Detail

TabletMapFile

public TabletMapFile(NConfiguration conf,
                     NeptuneFileSystem fs,
                     TabletInfo tabletInfo,
                     java.lang.String columnName,
                     java.lang.String fileId,
                     GPath filePath,
                     int numOfVersion)
              throws java.io.IOException

Throws:

java.io.IOException

TabletMapFile

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

Throws:

java.io.IOException

Method Detail

getTabletInfo

public TabletInfo getTabletInfo()

getColumnName

public java.lang.String getColumnName()

getMapFileWriter

public com.nhncorp.neptune.tabletserver.TabletMapFile.MapFileWriter getMapFileWriter()
                                                                              throws java.io.IOException

Throws:

java.io.IOException

getMapFileReader

public com.nhncorp.neptune.tabletserver.TabletMapFile.MapFileReader getMapFileReader(Row.Key startRowKey,
                                                                                     Row.Key endRowKey,
                                                                                     CellFilter cellFilter)
                                                                              throws java.io.IOException

Throws:

java.io.IOException

getMapFileReader

public com.nhncorp.neptune.tabletserver.TabletMapFile.MapFileReader getMapFileReader()
                                                                              throws java.io.IOException

Throws:

java.io.IOException

loadIndex

public boolean loadIndex()
                  throws java.io.IOException

Throws:

java.io.IOException

getIndexMemorySize

public long getIndexMemorySize()
                        throws java.io.IOException

Throws:

java.io.IOException

scan

public ValueCollection scan(Row.Key rowKey,
                            Cell.Key columnKey)
                     throws java.io.IOException

Throws:

java.io.IOException

scan

public java.util.List<ColumnValue> scan(Row.Key rowKey)
                                 throws java.io.IOException

Throws:

java.io.IOException

hasValue

public boolean hasValue(Row.Key rowKey)
                 throws java.io.IOException

Throws:

java.io.IOException

scanClosestColumnValues

public java.util.SortedSet<ColumnValue> scanClosestColumnValues(Row.Key rowKey,
                                                                MemorySSTableIF memorySSTable)
                                                         throws java.io.IOException

Throws:

java.io.IOException

findNearest

public MapFileIndexRecord findNearest(Row.Key targetRowKey,
                                      Cell.Key cellKey)
                               throws java.io.IOException

Throws:

java.io.IOException

getFilePath

public GPath getFilePath()

moveTo

public void moveTo(GPath targetPath,
                   boolean deleteParent)
            throws java.io.IOException

Throws:

java.io.IOException

delete

public boolean delete()
               throws java.io.IOException

Throws:

java.io.IOException

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getMapFileIndexRecords

public java.util.SortedSet<MapFileIndexRecord> getMapFileIndexRecords()

getDataFileSize

public long getDataFileSize()
                     throws java.io.IOException

Throws:

java.io.IOException

getFileId

public java.lang.String getFileId()

Returns:

the fileId

getFileSystem

public NeptuneFileSystem getFileSystem()

copyColumnValue

public static void copyColumnValue(MapFileColumnValue mapFileColumnValue,
                                   ColumnValue columnValue)

main

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

Throws:

java.io.IOException