|
Change Return Type List<String> to Map<LoadQueueItem,ByteBuffer> in method package performBulkLoad(admin Admin, table Table, regionLocator RegionLocator, queue Deque<LoadQueueItem>, pool ExecutorService, secureClient SecureBulkLoadClient, copyFile boolean) : Map<LoadQueueItem,ByteBuffer> in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |
|
Change Return Type List<String> to Map<LoadQueueItem,ByteBuffer> in method public doBulkLoad(map Map<byte[],List<Path>>, admin Admin, table Table, regionLocator RegionLocator, silence boolean, copyFile boolean) : Map<LoadQueueItem,ByteBuffer> in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |
|
Change Return Type List<String> to Map<LoadQueueItem,ByteBuffer> in method public run(dirPath String, map Map<byte[],List<Path>>, tableName TableName) : Map<LoadQueueItem,ByteBuffer> in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |
|
Change Return Type Pair<Multimap<ByteBuffer,LoadQueueItem>,List<String>> to Pair<Multimap<ByteBuffer,LoadQueueItem>,Set<String>> in method private groupOrSplitPhase(table Table, pool ExecutorService, queue Deque<LoadQueueItem>, startEndKeys Pair<byte[][],byte[][]>) : Pair<Multimap<ByteBuffer,LoadQueueItem>,Set<String>> in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |
|
Change Variable Type missingHFiles : List<String> to missingHFiles : Set<String> in method private groupOrSplitPhase(table Table, pool ExecutorService, queue Deque<LoadQueueItem>, startEndKeys Pair<byte[][],byte[][]>) : Pair<Multimap<ByteBuffer,LoadQueueItem>,Set<String>> in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |
|
Change Variable Type missingHFiles : List<String> to loaded : Map<LoadQueueItem,ByteBuffer> in method public run(args String[]) : int in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |
|
Change Variable Type missingHFiles : List<String> to loaded : Map<LoadQueueItem,ByteBuffer> in method private runTest(testName String, htd HTableDescriptor, bloomType BloomType, preCreateTable boolean, tableSplitKeys byte[][], hfileRanges byte[][][], useMap boolean, copyFiles boolean) : void in class org.apache.hadoop.hbase.mapreduce.TestLoadIncrementalHFiles |
From |
To |
|
Change Variable Type pair : Pair<Multimap<ByteBuffer,LoadQueueItem>,List<String>> to pair : Pair<Multimap<ByteBuffer,LoadQueueItem>,Set<String>> in method private groupOrSplitPhase(table Table, pool ExecutorService, queue Deque<LoadQueueItem>, startEndKeys Pair<byte[][],byte[][]>) : Pair<Multimap<ByteBuffer,LoadQueueItem>,Set<String>> in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |
|
Change Variable Type pair : Pair<Multimap<ByteBuffer,LoadQueueItem>,List<String>> to pair : Pair<Multimap<ByteBuffer,LoadQueueItem>,Set<String>> in method package performBulkLoad(admin Admin, table Table, regionLocator RegionLocator, queue Deque<LoadQueueItem>, pool ExecutorService, secureClient SecureBulkLoadClient, copyFile boolean) : Map<LoadQueueItem,ByteBuffer> in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |
|
Change Variable Type svrCallable : ClientServiceCallable<Boolean> to svrCallable : ClientServiceCallable<byte[]> in method protected tryAtomicRegionLoad(conn Connection, tableName TableName, first byte[], lqis Collection<LoadQueueItem>, copyFile boolean) : List<LoadQueueItem> in class org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles |
From |
To |