|
Pull Up Method private visitBulkHFiles(fs FileSystem, bulkDir Path, visitor BulkHFileVisitor<TFamily>) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private visitBulkHFiles(fs FileSystem, bulkDir Path, visitor BulkHFileVisitor<TFamily>) : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method private populateLoadQueue(ret Deque<LoadQueueItem>, map Map<byte[],List<Path>>) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private populateLoadQueue(ret Deque<LoadQueueItem>, map Map<byte[],List<Path>>) : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method public prepareHFileQueue(map Map<byte[],List<Path>>, table Table, queue Deque<LoadQueueItem>, silence boolean) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to public prepareHFileQueue(map Map<byte[],List<Path>>, table Table, queue Deque<LoadQueueItem>, silence boolean) : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method protected buildClientServiceCallable(conn Connection, tableName TableName, first byte[], lqis Collection<LoadQueueItem>, copyFile boolean) : ClientServiceCallable<byte[]> from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to protected buildClientServiceCallable(conn Connection, tableName TableName, first byte[], lqis Collection<LoadQueueItem>, copyFile boolean) : ClientServiceCallable<byte[]> from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method protected tryAtomicRegionLoad(serviceCallable ClientServiceCallable<byte[]>, tableName TableName, first byte[], lqis Collection<LoadQueueItem>) : List<LoadQueueItem> from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to protected tryAtomicRegionLoad(serviceCallable ClientServiceCallable<byte[]>, tableName TableName, first byte[], lqis Collection<LoadQueueItem>) : List<LoadQueueItem> from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method private validateFamiliesInHFiles(table Table, queue Deque<LoadQueueItem>, silence boolean) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private validateFamiliesInHFiles(table Table, queue Deque<LoadQueueItem>, silence boolean) : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method private groupOrSplitPhase(table Table, pool ExecutorService, queue Deque<LoadQueueItem>, startEndKeys Pair<byte[][],byte[][]>) : Pair<Multimap<ByteBuffer,LoadQueueItem>,Set<String>> from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private groupOrSplitPhase(table Table, pool ExecutorService, queue Deque<LoadQueueItem>, startEndKeys Pair<byte[][],byte[][]>) : Pair<Multimap<ByteBuffer,LoadQueueItem>,Set<String>> from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method private checkHFilesCountPerRegionPerFamily(regionGroups Multimap<ByteBuffer,LoadQueueItem>) : boolean from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private checkHFilesCountPerRegionPerFamily(regionGroups Multimap<ByteBuffer,LoadQueueItem>) : boolean from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method private toString(list List<Pair<byte[],String>>) : String from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private toString(list List<Pair<byte[],String>>) : String from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method private discoverLoadQueue(ret Deque<LoadQueueItem>, hfofDir Path, validateHFile boolean) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private discoverLoadQueue(ret Deque<LoadQueueItem>, hfofDir Path, validateHFile boolean) : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method public setBulkToken(stagingDir String) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to public setBulkToken(stagingDir String) : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method public loadHFileQueue(table Table, conn Connection, queue Deque<LoadQueueItem>, startEndKeys Pair<byte[][],byte[][]>) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to public loadHFileQueue(table Table, conn Connection, queue Deque<LoadQueueItem>, startEndKeys Pair<byte[][],byte[][]>) : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method private getUniqueName() : String from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private getUniqueName() : String from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method private isSecureBulkLoadEndpointAvailable() : boolean from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private isSecureBulkLoadEndpointAvailable() : boolean from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method protected groupOrSplit(regionGroups Multimap<ByteBuffer,LoadQueueItem>, item LoadQueueItem, table Table, startEndKeys Pair<byte[][],byte[][]>) : Pair<List<LoadQueueItem>,String> from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to protected groupOrSplit(regionGroups Multimap<ByteBuffer,LoadQueueItem>, item LoadQueueItem, table Table, startEndKeys Pair<byte[][],byte[][]>) : Pair<List<LoadQueueItem>,String> from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method protected bulkLoadPhase(table Table, conn Connection, pool ExecutorService, queue Deque<LoadQueueItem>, regionGroups Multimap<ByteBuffer,LoadQueueItem>, copyFile boolean, item2RegionMap Map<LoadQueueItem,ByteBuffer>) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to protected bulkLoadPhase(table Table, conn Connection, pool ExecutorService, queue Deque<LoadQueueItem>, regionGroups Multimap<ByteBuffer,LoadQueueItem>, copyFile boolean, item2RegionMap Map<LoadQueueItem,ByteBuffer>) : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method public run(args String[]) : int from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to public run(args String[]) : int from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method private shouldCopyHFileMetaKey(key byte[]) : boolean from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private shouldCopyHFileMetaKey(key byte[]) : boolean from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method public loadHFileQueue(table Table, conn Connection, queue Deque<LoadQueueItem>, startEndKeys Pair<byte[][],byte[][]>, copyFile boolean) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to public loadHFileQueue(table Table, conn Connection, queue Deque<LoadQueueItem>, startEndKeys Pair<byte[][],byte[][]>, copyFile boolean) : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method package performBulkLoad(admin Admin, table Table, regionLocator RegionLocator, queue Deque<LoadQueueItem>, pool ExecutorService, secureClient SecureBulkLoadClient, copyFile boolean) : Map<LoadQueueItem,ByteBuffer> from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private performBulkLoad(admin Admin, table Table, regionLocator RegionLocator, queue Deque<LoadQueueItem>, pool ExecutorService, secureClient SecureBulkLoadClient, copyFile boolean) : Map<LoadQueueItem,ByteBuffer> from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method protected splitStoreFile(item LoadQueueItem, table Table, startKey byte[], splitKey byte[]) : List<LoadQueueItem> from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private splitStoreFile(item LoadQueueItem, table Table, startKey byte[], splitKey byte[]) : List<LoadQueueItem> from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method private createExecutorService() : ExecutorService from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private createExecutorService() : ExecutorService from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method package cleanup(admin Admin, queue Deque<LoadQueueItem>, pool ExecutorService, secureClient SecureBulkLoadClient) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private cleanup(admin Admin, queue Deque<LoadQueueItem>, pool ExecutorService, secureClient SecureBulkLoadClient) : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method public prepareHFileQueue(hfilesDir Path, table Table, queue Deque<LoadQueueItem>, validateHFile boolean) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to public prepareHFileQueue(hfilesDir Path, table Table, queue Deque<LoadQueueItem>, validateHFile boolean) : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method private visitBulkHFiles(fs FileSystem, bulkDir Path, visitor BulkHFileVisitor<TFamily>, validateHFile boolean) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private visitBulkHFiles(fs FileSystem, bulkDir Path, visitor BulkHFileVisitor<TFamily>, validateHFile boolean) : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method public main(args String[]) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to public main(args String[]) : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method private usage() : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private usage() : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method private createTable(tableName TableName, dirPath String, admin Admin) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private createTable(tableName TableName, dirPath String, admin Admin) : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Method public prepareHFileQueue(hfilesDir Path, table Table, queue Deque<LoadQueueItem>, validateHFile boolean, silence boolean) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to public prepareHFileQueue(hfilesDir Path, table Table, queue Deque<LoadQueueItem>, validateHFile boolean, silence boolean) : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Move Method public doBulkLoad(hfofDir Path, admin Admin, table Table, regionLocator RegionLocator) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to public doBulkLoad(hfofDir Path, admin Admin, table Table, regionLocator RegionLocator) : Map<LoadQueueItem,ByteBuffer> from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Move Method private copyHFileHalf(conf Configuration, inFile Path, outFile Path, reference Reference, familyDescriptor HColumnDescriptor) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private copyHFileHalf(conf Configuration, inFile Path, outFile Path, reference Reference, familyDescriptor ColumnFamilyDescriptor) : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Move Method public doBulkLoad(hfofDir Path, admin Admin, table Table, regionLocator RegionLocator, silence boolean, copyFile boolean) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to public doBulkLoad(hfofDir Path, admin Admin, table Table, regionLocator RegionLocator, silence boolean, copyFile boolean) : Map<LoadQueueItem,ByteBuffer> from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Move Method public doBulkLoad(map Map<byte[],List<Path>>, admin Admin, table Table, regionLocator RegionLocator, silence boolean, copyFile boolean) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to public doBulkLoad(map Map<byte[],List<Path>>, admin Admin, table Table, regionLocator RegionLocator, silence boolean, copyFile boolean) : Map<LoadQueueItem,ByteBuffer> from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Move Method public getFilePath() : Path from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem to public getFilePath() : Path from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles.LoadQueueItem |
From |
To |
|
Move Method package splitStoreFile(conf Configuration, inFile Path, familyDesc HColumnDescriptor, splitKey byte[], bottomOut Path, topOut Path) : void from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to package splitStoreFile(conf Configuration, inFile Path, familyDesc ColumnFamilyDescriptor, splitKey byte[], bottomOut Path, topOut Path) : void from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Move Method public getFamily() : byte[] from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem to public getFamily() : byte[] from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles.LoadQueueItem |
From |
To |
|
Move Method public toString() : String from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem to public toString() : String from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles.LoadQueueItem |
From |
To |
|
Move Method public inferBoundaries(bdryMap TreeMap<byte[],Integer>) : byte[][] from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to public inferBoundaries(bdryMap SortedMap<byte[],Integer>) : byte[][] from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Attribute public IGNORE_UNMATCHED_CF_CONF_KEY : String from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to public IGNORE_UNMATCHED_CF_CONF_KEY : String from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Attribute private LOG : Log from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private LOG : Log from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Attribute private fsDelegationToken : FsDelegationToken from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private fsDelegationToken : FsDelegationToken from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Attribute private nrThreads : int from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private nrThreads : int from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Attribute private maxFilesPerRegionPerFamily : int from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private maxFilesPerRegionPerFamily : int from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Attribute public CREATE_TABLE_CONF_KEY : String from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to public CREATE_TABLE_CONF_KEY : String from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Attribute public MAX_FILES_PER_REGION_PER_FAMILY : String from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to public MAX_FILES_PER_REGION_PER_FAMILY : String from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Attribute public ALWAYS_COPY_FILES : String from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to public ALWAYS_COPY_FILES : String from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Attribute private bulkToken : String from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private bulkToken : String from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Attribute private userProvider : UserProvider from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private userProvider : UserProvider from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Attribute public NAME : String from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to public NAME : String from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Attribute private rpcControllerFactory : RpcControllerFactory from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private rpcControllerFactory : RpcControllerFactory from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Attribute package RETRY_ON_IO_EXCEPTION : String from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to package RETRY_ON_IO_EXCEPTION : String from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Attribute private assignSeqIds : boolean from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private assignSeqIds : boolean from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Attribute package TMP_DIR : String from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to package TMP_DIR : String from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |
|
Pull Up Attribute private ASSIGN_SEQ_IDS : String from class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles to private ASSIGN_SEQ_IDS : String from class org.apache.hadoop.hbase.tool.LoadIncrementalHFiles |
From |
To |