|
Change Return Type Multimap<ByteBuffer,LoadQueueItem> to Pair<Multimap<ByteBuffer,LoadQueueItem>,List<String>> in method private groupOrSplitPhase(table Table, pool ExecutorService, queue Deque<LoadQueueItem>, startEndKeys Pair<byte[][],byte[][]>) : Pair<Multimap<ByteBuffer,LoadQueueItem>,List<String>> in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |
|
Change Return Type int to List<String> in method public run(dirPath String, map Map<byte[],List<Path>>, tableName TableName) : List<String> in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |
|
Change Return Type void to List<String> in method public doBulkLoad(map Map<byte[],List<Path>>, admin Admin, table Table, regionLocator RegionLocator, silence boolean, copyFile boolean) : List<String> in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |
|
Change Return Type void to List<String> in method package performBulkLoad(admin Admin, table Table, regionLocator RegionLocator, queue Deque<LoadQueueItem>, pool ExecutorService, secureClient SecureBulkLoadClient, copyFile boolean) : List<String> in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |
|
Change Return Type List<LoadQueueItem> to Pair<List<LoadQueueItem>,String> in method protected groupOrSplit(regionGroups Multimap<ByteBuffer,LoadQueueItem>, item LoadQueueItem, table Table, startEndKeys Pair<byte[][],byte[][]>) : Pair<List<LoadQueueItem>,String> in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |
|
Change Variable Type lqis : List<LoadQueueItem> to lqis : Pair<List<LoadQueueItem>,String> in method protected groupOrSplit(regionGroups Multimap<ByteBuffer,LoadQueueItem>, item LoadQueueItem, htable Table, startEndKeys Pair<byte[][],byte[][]>) : Pair<List<LoadQueueItem>,String> in class org.apache.hadoop.hbase.mapreduce.TestLoadIncrementalHFilesSplitRecovery.testGroupOrSplitPresplit.lih |
From |
To |
|
Change Variable Type splits : List<LoadQueueItem> to splits : Pair<List<LoadQueueItem>,String> in method private groupOrSplitPhase(table Table, pool ExecutorService, queue Deque<LoadQueueItem>, startEndKeys Pair<byte[][],byte[][]>) : Pair<Multimap<ByteBuffer,LoadQueueItem>,List<String>> in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |
|
Change Variable Type call : Callable<List<LoadQueueItem>> to call : Callable<Pair<List<LoadQueueItem>,String>> in method private groupOrSplitPhase(table Table, pool ExecutorService, queue Deque<LoadQueueItem>, startEndKeys Pair<byte[][],byte[][]>) : Pair<Multimap<ByteBuffer,LoadQueueItem>,List<String>> in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |
|
Change Variable Type lqis : Future<List<LoadQueueItem>> to lqis : Future<Pair<List<LoadQueueItem>,String>> in method private groupOrSplitPhase(table Table, pool ExecutorService, queue Deque<LoadQueueItem>, startEndKeys Pair<byte[][],byte[][]>) : Pair<Multimap<ByteBuffer,LoadQueueItem>,List<String>> in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |
|
Change Variable Type splittingFutures : Set<Future<List<LoadQueueItem>>> to splittingFutures : Set<Future<Pair<List<LoadQueueItem>,String>>> in method private groupOrSplitPhase(table Table, pool ExecutorService, queue Deque<LoadQueueItem>, startEndKeys Pair<byte[][],byte[][]>) : Pair<Multimap<ByteBuffer,LoadQueueItem>,List<String>> in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |
|
Change Variable Type lqis : List<LoadQueueItem> to lqis : Pair<List<LoadQueueItem>,String> in method protected groupOrSplit(regionGroups Multimap<ByteBuffer,LoadQueueItem>, item LoadQueueItem, htable Table, startEndKeys Pair<byte[][],byte[][]>) : Pair<List<LoadQueueItem>,String> in class org.apache.hadoop.hbase.mapreduce.TestLoadIncrementalHFilesSplitRecovery.testGroupOrSplitWhenRegionHoleExistsInMeta.loader |
From |
To |