|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use TabletInfo | |
|---|---|
| com.nhncorp.neptune.client | Neptune Client API, Shell, Scanner, Utility |
| com.nhncorp.neptune.client.scanner | scanner, ScannerFactory만 외부에 오픈되고 대부분은 protected |
| com.nhncorp.neptune.master | Neptune Master Server |
| com.nhncorp.neptune.tablet | Table, Tablet 관련 Value Object |
| com.nhncorp.neptune.tabletserver | TabletServer |
| com.nhncorp.neptune.tabletserver.action | |
| Uses of TabletInfo in com.nhncorp.neptune.client |
|---|
| Methods in com.nhncorp.neptune.client that return TabletInfo | |
|---|---|
TabletInfo |
NTable.addTablet(Row.Key endRowKey)
테이블에 새로운 Tablet을 추가한다 |
TabletInfo |
NTable.getTabletInfo(java.lang.String tabletName)
|
TabletInfo[] |
NTable.listTabletInfos()
특정 테이블의 Tablet 목록을 가져온다. |
static TabletInfo |
NTable.lookupTargetTablet(NConfiguration conf,
java.lang.String tableName,
Row.Key rowKey)
특정 Row를 서비스하는 Tablet을 찾는다. |
TabletInfo |
NTable.lookupTargetTablet(Row.Key rowKey)
BatchUpload를 종료한다. |
| Methods in com.nhncorp.neptune.client with parameters of type TabletInfo | |
|---|---|
void |
TabletLocationCache.addCache(java.util.TreeMap<Row.Key,TabletInfo> cache,
Row.Key lookupRowKey,
TabletInfo tabletInfo,
Row.Key cacheEndRowKey)
|
void |
TabletLocationCache.clearTabletCache(java.lang.String tableName,
Row.Key rowKey,
TabletInfo tabletInfo)
|
static DataServiceProtocol |
NTableManager.connectTabletServer(TabletInfo tabletInfo,
NConfiguration conf)
|
Row.Key[] |
NTable.getSplitedRowKeyRanges(TabletInfo tabletInfo,
int splitPerTablet)
|
java.lang.String[] |
NTable.getTabletAllActions(TabletInfo tabletInfo)
Tablet에 현재 수행중인 작업을 조회한다. |
TabletReport |
NTable.getTabletReport(TabletInfo tabletInfo)
Tablet의 현재 상황을 모니터링한다. |
| Method parameters in com.nhncorp.neptune.client with type arguments of type TabletInfo | |
|---|---|
void |
TabletLocationCache.addCache(java.util.TreeMap<Row.Key,TabletInfo> cache,
Row.Key lookupRowKey,
TabletInfo tabletInfo,
Row.Key cacheEndRowKey)
|
| Uses of TabletInfo in com.nhncorp.neptune.client.scanner |
|---|
| Methods in com.nhncorp.neptune.client.scanner with parameters of type TabletInfo | |
|---|---|
static TableScanner |
ScannerFactory.openScanner(NConfiguration conf,
TabletInfo tabletInfo,
RowFilter rowFilter)
특정 Tablet을 Scan하는 TableScanner를 오픈한다. |
static TableScanner |
ScannerFactory.openScanner(NConfiguration conf,
TabletInfo tabletInfo,
java.lang.String columnName)
특정 Tablet을 Scan하는 TableScanner를 오픈한다. |
static TableScanner |
ScannerFactory.openScanner(NConfiguration conf,
TabletInfo tabletInfo,
java.lang.String[] columnNames)
특정 Tablet을 Scan하는 TableScanner를 오픈한다. |
| Uses of TabletInfo in com.nhncorp.neptune.master |
|---|
| Methods in com.nhncorp.neptune.master that return TabletInfo | |
|---|---|
TabletInfo |
TableManagerProtocol.addTablet(java.lang.String tableName,
Row.Key endRowKey)
테이블에 새로운 Tablet을 추가한다. |
TabletInfo |
NeptuneMaster.addTablet(java.lang.String tableName,
Row.Key endRowKey)
|
TabletInfo[] |
TableManagerProtocol.getTablets(java.lang.String tableName)
특정 테이블의 Tablet 목록을 조회한다. |
TabletInfo[] |
NeptuneMaster.getTablets(java.lang.String tableName)
|
| Methods in com.nhncorp.neptune.master with parameters of type TabletInfo | |
|---|---|
boolean |
TabletMasterProtocol.assignTablet(TabletInfo tabletInfo)
|
boolean |
NeptuneMaster.assignTablet(TabletInfo tabletInfo)
Tablet을 tablet server에 할당한다. ignoreFlag는 tablet이 현재 다른 tabletserver에 의해 로딩중이거나 서비스중에 상관없이 지정된 tablet server로 할당된다. |
void |
TabletMasterProtocol.endTabletAssignment(TabletInfo tabletInfo,
boolean created)
|
void |
NeptuneMaster.endTabletAssignment(TabletInfo tabletInfo,
boolean created)
|
void |
NeptuneMasterIF.endTabletAssignmentForHandler(TabletInfo tabletInfo,
boolean created)
|
void |
NeptuneMaster.endTabletAssignmentForHandler(TabletInfo tabletInfo,
boolean created)
Proxy를 이용해서 테스트 코드를 작성하기 위해 인터페이스로 빼서 처리, 실제는 endTabletAssignment 처리 |
void |
TabletMasterProtocol.errorTabletAssignment(java.lang.String hostName,
TabletInfo tabletInfo)
|
void |
NeptuneMaster.errorTabletAssignment(java.lang.String hostName,
TabletInfo tabletInfo)
Tablet할당 에러 발생시 다음과 같이 처리한다. 1. |
void |
TabletMasterProtocol.reportTabletSplited(TabletInfo targetTablet,
TabletInfo[] splitedTablets)
|
void |
TabletMasterProtocol.reportTabletSplited(TabletInfo targetTablet,
TabletInfo[] splitedTablets)
|
void |
NeptuneMaster.reportTabletSplited(TabletInfo targetTablet,
TabletInfo[] splitedTablets)
|
void |
NeptuneMaster.reportTabletSplited(TabletInfo targetTablet,
TabletInfo[] splitedTablets)
|
| Uses of TabletInfo in com.nhncorp.neptune.tablet |
|---|
| Methods in com.nhncorp.neptune.tablet that return TabletInfo | |
|---|---|
TabletInfo |
TabletReport.getTabletInfo()
|
| Methods in com.nhncorp.neptune.tablet with parameters of type TabletInfo | |
|---|---|
void |
TabletReport.setTabletInfo(TabletInfo tabletInfo)
|
| Uses of TabletInfo in com.nhncorp.neptune.tabletserver |
|---|
| Methods in com.nhncorp.neptune.tabletserver that return TabletInfo | |
|---|---|
static TabletInfo |
Tablet.getRootTabletInfo(com.nhncorp.pleiades.client.LockService lockService)
|
TabletInfo |
TabletMapFile.getTabletInfo()
|
TabletInfo |
Tablet.getTabletInfo()
|
TabletInfo |
DiskSSTable.getTabletInfo()
|
TabletInfo |
TabletServer.getTabletInfo(java.lang.String tabletName)
|
TabletInfo |
TabletManagerProtocol.getTabletInfo(java.lang.String tabletName)
|
TabletInfo |
DataServiceProtocol.getTabletInfo(java.lang.String tabletName)
|
TabletInfo[] |
TabletServer.reportTablets()
|
TabletInfo[] |
TabletManagerProtocol.reportTablets()
|
| Methods in com.nhncorp.neptune.tabletserver with parameters of type TabletInfo | |
|---|---|
void |
TabletServer.assignTablet(TabletInfo tabletInfo)
|
void |
TabletManagerProtocol.assignTablet(TabletInfo tabletInfo)
|
void |
TabletServerIF.endTabletAssignmentForHandler(TabletInfo tabletInfo,
boolean create)
|
void |
TabletServer.endTabletAssignmentForHandler(TabletInfo tabletInfo,
boolean create)
테스트 코드를 위해 NeptuneMaster로 전송하는 부분을 인터페이스로 빼서 처리. |
static java.lang.String |
TabletScanner.generateScannerId(TabletInfo tabletInfo)
|
static GPath |
ChangeLog.getChangeLogPath(NConfiguration conf,
TabletInfo tabletInfo)
|
static GPath |
ChangeLog.getChangeLogTempPath(NConfiguration conf,
TabletInfo tabletInfo,
java.lang.String fileId)
|
static GPath |
Tablet.getTabletLocalTempPath(NConfiguration conf,
TabletInfo tabletInfo,
java.lang.String actionId)
|
static GPath |
Tablet.getTabletMajorCompactionTempPath(NConfiguration conf,
TabletInfo tabletInfo)
|
static GPath |
Tablet.getTabletMinorCompactionTempPath(NConfiguration conf,
TabletInfo tabletInfo)
|
static GPath |
Tablet.getTabletPath(NConfiguration conf,
TabletInfo tabletInfo)
|
static GPath |
Tablet.getTabletSplitTempPath(NConfiguration conf,
TabletInfo tabletInfo)
|
static GPath |
Tablet.getTabletUploadTempPath(NConfiguration conf,
TabletInfo tabletInfo,
java.lang.String actionId)
|
void |
DiskSSTableIF.init(TabletServerIF tabletServer,
DiskSSTableIF proxyObject,
NConfiguration conf,
TabletInfo tabletInfo,
int numOfVersion)
|
void |
DiskSSTable.init(TabletServerIF tabletServer,
DiskSSTableIF proxyObject,
NConfiguration conf,
TabletInfo tabletInfo,
int numOfVersion)
|
void |
MemorySSTableIF.init(TabletServerIF tabletServer,
NConfiguration conf,
TabletInfo tabletInfo,
int nemOfVersion)
|
void |
MemorySSTable.init(TabletServerIF tabletServer,
NConfiguration conf,
TabletInfo tabletInfo,
int numOfVersion)
|
static TabletMapFile |
DiskSSTable.mergeColumnMapFiles(NConfiguration conf,
NeptuneFileSystem resultFs,
GPath resultPath,
TabletInfo tabletInfo,
java.lang.String fileId,
java.lang.String columnName,
java.util.List<TabletMapFile> mergeMapFiles,
int numOfVersion)
|
void |
TabletServer.saveTabletSplitedInfo(java.lang.String tabletName,
TabletInfo targetTablet,
TabletInfo[] splitedTablets)
|
void |
TabletServer.saveTabletSplitedInfo(java.lang.String tabletName,
TabletInfo targetTablet,
TabletInfo[] splitedTablets)
|
void |
DataServiceProtocol.saveTabletSplitedInfo(java.lang.String tabletName,
TabletInfo targetTablet,
TabletInfo[] splitedTablets)
|
void |
DataServiceProtocol.saveTabletSplitedInfo(java.lang.String tabletName,
TabletInfo targetTablet,
TabletInfo[] splitedTablets)
|
void |
Tablet.saveTabletSplitedInfo(TxId txId,
TabletInfo targetTablet,
TabletInfo[] splitedTablets)
META/ROOT tablet에 split된 tablet 정보를 저장한다. 3개의 작업(1 delete, 2 insert)이 하나의 change log에 저장되도록한다. |
void |
Tablet.saveTabletSplitedInfo(TxId txId,
TabletInfo targetTablet,
TabletInfo[] splitedTablets)
META/ROOT tablet에 split된 tablet 정보를 저장한다. 3개의 작업(1 delete, 2 insert)이 하나의 change log에 저장되도록한다. |
java.util.Map<java.lang.String,TabletMapFile> |
MemorySSTableIF.saveToDisk(TabletInfo tabletInfo,
java.lang.String fileId)
|
java.util.Map<java.lang.String,TabletMapFile> |
MemorySSTable.saveToDisk(TabletInfo tabletInfo,
java.lang.String fileId)
임시버퍼(compactingColumnCollections)에 저장된 데이터를 파일로 저장한다. |
TabletMapFile |
ColumnCollection.saveToDisk(TabletInfo tabletInfo,
java.lang.String columnName,
java.lang.String fileId,
int numOfVersion)
데이터를 임시 디렉토리에 저장한다. |
TabletMapFile |
ColumnCollection.saveToLocalDisk(NeptuneFileSystem fs,
TabletInfo tabletInfo,
java.lang.String columnName,
java.lang.String fileId,
java.lang.String uploadAcitonId,
int numOfVersion)
BatchUpload를 위해 임시로 로컬 파일시스템에 저장시킨다. |
DiskSSTableIF[] |
DiskSSTableIF.split(Row.Key midRowaKey,
TabletInfo[] splitedTabletInfos)
|
DiskSSTableIF[] |
DiskSSTable.split(Row.Key midRowKey,
TabletInfo[] createdTablets)
Tablet의 크기가 정해진 크기보다 큰 경우 Tablet을 두개로 쪼갠다. |
java.util.Map<java.lang.String,TabletMapFile[]> |
MemorySSTableIF.splitAndSave(Row.Key midRowKey,
TabletInfo[] splitedTabletInfos)
|
java.util.Map<java.lang.String,TabletMapFile[]> |
MemorySSTable.splitAndSave(Row.Key midRowKey,
TabletInfo[] splitedTabletInfos)
|
TabletMapFile[] |
ColumnCollection.splitAndSaveToDisk(TabletInfo tabletInfo,
Row.Key midRowKey,
TabletInfo[] splitedTabletInfos,
java.lang.String columnName,
java.lang.String fileId,
int numOfVersion)
|
TabletMapFile[] |
ColumnCollection.splitAndSaveToDisk(TabletInfo tabletInfo,
Row.Key midRowKey,
TabletInfo[] splitedTabletInfos,
java.lang.String columnName,
java.lang.String fileId,
int numOfVersion)
|
void |
TabletServer.splitForTest(TabletInfo tabletInfo)
|
void |
TabletManagerProtocol.splitForTest(TabletInfo tabletInfo)
|
void |
DiskSSTableIF.splitMapFile(Row.Key midRowKey,
TabletInfo[] createdTablets,
DiskSSTableIF[] createdDiskSSTables,
java.lang.String columnName,
TabletMapFile columnMapFile,
java.lang.String fileId)
|
void |
DiskSSTable.splitMapFile(Row.Key midRowKey,
TabletInfo[] createdTablets,
DiskSSTableIF[] createdDiskSSTables,
java.lang.String columnName,
TabletMapFile tabletMapFile,
java.lang.String fileId)
|
| Constructors in com.nhncorp.neptune.tabletserver with parameters of type TabletInfo | |
|---|---|
ChangeLogWriter(NConfiguration conf,
ChangeLogFileSystem changeLogFileSystem,
TabletInfo tabletInfo)
|
|
Tablet(NConfiguration conf,
TableSchema table,
TabletServer tabletServer,
TabletInfo tabletInfo)
|
|
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)
|
|
TabletScanner(java.lang.String scannerId,
NConfiguration conf,
TabletInfo tabletInfo,
Row.Key startRowKey,
Row.Key endRowKey,
java.lang.String columnName,
MemorySSTableIF memorySSTable,
DiskSSTableIF diskSSTable,
CellFilter columnFilter,
int numOfVersion)
|
|
UploaderCache(NConfiguration conf,
TabletInfo tabletInfo,
java.lang.String[] columnNames,
java.lang.String uploadActionId,
int numOfVersion)
|
|
| Uses of TabletInfo in com.nhncorp.neptune.tabletserver.action |
|---|
| Methods in com.nhncorp.neptune.tabletserver.action with parameters of type TabletInfo | |
|---|---|
void |
TabletDropActionIF.init(TabletServer tabletServer,
TabletDropActionIF proxyObject,
com.nhncorp.pleiades.client.LockService lockService,
TabletInfo tabletInfo)
|
void |
TabletDropAction.init(TabletServer tabletServer,
TabletDropActionIF proxyObject,
com.nhncorp.pleiades.client.LockService lockService,
TabletInfo tabletInfo)
|
| Constructors in com.nhncorp.neptune.tabletserver.action with parameters of type TabletInfo | |
|---|---|
ActionChecker(java.util.concurrent.ExecutorService compactionExecutor,
java.util.concurrent.ExecutorService splitExecutor,
java.util.concurrent.ExecutorService actionExecutor,
java.lang.ThreadGroup threadGroup,
TabletInfo tabletInfo)
|
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||