com.nhncorp.neptune.tabletserver
Class UploaderCache

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

public class UploaderCache
extends java.lang.Object

Merge 속도: . 51개 파일, 2.7GB -> 11m8.723s(로컬로 저장), 10m38.885s(HDFS)

Author:

nhn

Field Summary

static org.apache.commons.logging.Log

LOG

Constructor Summary

UploaderCache(NConfiguration conf, TabletInfo tabletInfo, java.lang.String[] columnNames, java.lang.String uploadActionId, int numOfVersion)

Method Summary

void	addColumnRecords(Row.Key rowKey, ColumnValue[][] columnValues)
java.util.Map<java.lang.String,TabletMapFile>	close()
void	init()
static void	main(java.lang.String[] args)
void	saveToDisk()

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

UploaderCache

public UploaderCache(NConfiguration conf,
                     TabletInfo tabletInfo,
                     java.lang.String[] columnNames,
                     java.lang.String uploadActionId,
                     int numOfVersion)
              throws java.io.IOException

Throws:

java.io.IOException

Method Detail

addColumnRecords

public void addColumnRecords(Row.Key rowKey,
                             ColumnValue[][] columnValues)
                      throws java.io.IOException

Throws:

java.io.IOException

saveToDisk

public void saveToDisk()
                throws java.io.IOException

Throws:

java.io.IOException

close

public java.util.Map<java.lang.String,TabletMapFile> close()
                                                    throws java.io.IOException

Throws:

java.io.IOException

init

public void init()

main

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

Throws:

java.io.IOException