diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/SimpleRequestController.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/SimpleRequestController.java index ce260ee11e0..4981d62a605 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/SimpleRequestController.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/SimpleRequestController.java @@ -433,7 +433,7 @@ class SimpleRequestController implements RequestController { * * @param loc * @param heapSizeOfRow - * @return + * @return either Include {@link ReturnCode} or Skip {@link ReturnCode} */ @Override public ReturnCode canTakeOperation(HRegionLocation loc, long heapSizeOfRow) { diff --git a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/mapred/TestTableInputFormat.java b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/mapred/TestTableInputFormat.java index 9a528a6791b..94fe1e69275 100644 --- a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/mapred/TestTableInputFormat.java +++ b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/mapred/TestTableInputFormat.java @@ -143,11 +143,11 @@ public class TestTableInputFormat { /** * Verify that the result and key have expected values. * - * @param r - * @param key - * @param expectedKey - * @param expectedValue - * @return + * @param r single row result + * @param key the row key + * @param expectedKey the expected key + * @param expectedValue the expected value + * @return true if the result contains the expected key and value, false otherwise. */ static boolean checkResult(Result r, ImmutableBytesWritable key, byte[] expectedKey, byte[] expectedValue) { diff --git a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/mapreduce/TestTableInputFormat.java b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/mapreduce/TestTableInputFormat.java index 55a794ddb4c..a0483d53af5 100644 --- a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/mapreduce/TestTableInputFormat.java +++ b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/mapreduce/TestTableInputFormat.java @@ -141,11 +141,11 @@ public class TestTableInputFormat { /** * Verify that the result and key have expected values. * - * @param r - * @param key - * @param expectedKey - * @param expectedValue - * @return + * @param r single row result + * @param key the row key + * @param expectedKey the expected key + * @param expectedValue the expected value + * @return true if the result contains the expected key and value, false otherwise. */ static boolean checkResult(Result r, ImmutableBytesWritable key, byte[] expectedKey, byte[] expectedValue) { diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/client/VersionInfoUtil.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/client/VersionInfoUtil.java index 0f190f8ce33..8418161048f 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/client/VersionInfoUtil.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/client/VersionInfoUtil.java @@ -149,7 +149,7 @@ public final class VersionInfoUtil { /** * Returns the version components * Examples: "1.4.3" returns [1, 4, 3], "4.5.6-SNAPSHOT" returns [4, 5, 6, "SNAPSHOT"] - * @returns the components of the version string + * @return the components of the version string */ private static String[] getVersionComponents(final HBaseProtos.VersionInfo versionInfo) { return versionInfo.getVersion().split("[\\.-]"); diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/client/locking/EntityLock.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/client/locking/EntityLock.java index b956e337005..e49fe8c8c93 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/client/locking/EntityLock.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/client/locking/EntityLock.java @@ -218,8 +218,7 @@ public class EntityLock { } /** - * Shutdown the thread cleanly, quietly. We done. - * @return + * @return Shuts down the thread clean and quietly. */ Thread shutdown() { shutdown = true; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java index f8d59924c32..12b3bc5a3b3 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java @@ -4089,8 +4089,8 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi /** * Called to do a piece of the batch that came in to {@link #batchMutate(Mutation[], long, long)} - * In here we also handle replay of edits on region recover. - * @return Change in size brought about by applying batchOp + * In here we also handle replay of edits on region recover. Also gets change in size brought + * about by applying {@code batchOp}. */ private void doMiniBatchMutate(BatchOperation batchOp) throws IOException { boolean success = false; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreLABImpl.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreLABImpl.java index 6f1ee92a15a..e893359e920 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreLABImpl.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreLABImpl.java @@ -300,7 +300,6 @@ public class MemStoreLABImpl implements MemStoreLAB { * c. Postcondition is that curChunk.get() * != c * @param c the chunk to retire - * @return true if we won the race to retire the chunk */ private void tryRetireChunk(Chunk c) { currChunk.compareAndSet(c, null); diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java index e27735afd8a..61354fda588 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java @@ -539,7 +539,7 @@ public class RSRpcServices implements HBaseRPCErrorHandler, * Starts the nonce operation for a mutation, if needed. * @param mutation Mutation. * @param nonceGroup Nonce group from the request. - * @returns whether to proceed this mutation. + * @return whether to proceed this mutation. */ private boolean startNonceOperation(final MutationProto mutation, long nonceGroup) throws IOException { diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/SnapshotInfo.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/SnapshotInfo.java index b1514f7b09c..85a45ee45eb 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/SnapshotInfo.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/SnapshotInfo.java @@ -614,7 +614,6 @@ public final class SnapshotInfo extends AbstractHBaseTool { * @param uniqueHFilesArchiveSize {@link AtomicLong} the accumulated store file size in archive * @param uniqueHFilesSize {@link AtomicLong} the accumulated store file size shared * @param uniqueHFilesMobSize {@link AtomicLong} the accumulated mob store file size shared - * @return the snapshot stats */ private static void getSnapshotFilesMap(final Configuration conf, final SnapshotDescription snapshot, final ExecutorService exec, diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseCluster.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseCluster.java index 8020553e4f5..3a1c8945f2a 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseCluster.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseCluster.java @@ -118,14 +118,12 @@ public abstract class HBaseCluster implements Closeable, Configurable { /** * Stops the given region server, by attempting a gradual stop. - * @return whether the operation finished with success * @throws IOException if something goes wrong */ public abstract void stopRegionServer(ServerName serverName) throws IOException; /** * Wait for the specified region server to join the cluster - * @return whether the operation finished with success * @throws IOException if something goes wrong or timeout occurs */ public void waitForRegionServerToStart(String hostname, int port, long timeout) @@ -145,7 +143,6 @@ public abstract class HBaseCluster implements Closeable, Configurable { /** * Wait for the specified region server to stop the thread / process. - * @return whether the operation finished with success * @throws IOException if something goes wrong or timeout occurs */ public abstract void waitForRegionServerToStop(ServerName serverName, long timeout) @@ -175,7 +172,6 @@ public abstract class HBaseCluster implements Closeable, Configurable { /** * Wait for the specified zookeeper node to join the cluster - * @return whether the operation finished with success * @throws IOException if something goes wrong or timeout occurs */ public abstract void waitForZkNodeToStart(ServerName serverName, long timeout) @@ -183,7 +179,6 @@ public abstract class HBaseCluster implements Closeable, Configurable { /** * Wait for the specified zookeeper node to stop the thread / process. - * @return whether the operation finished with success * @throws IOException if something goes wrong or timeout occurs */ public abstract void waitForZkNodeToStop(ServerName serverName, long timeout) @@ -212,7 +207,6 @@ public abstract class HBaseCluster implements Closeable, Configurable { /** * Wait for the specified datanode to join the cluster - * @return whether the operation finished with success * @throws IOException if something goes wrong or timeout occurs */ public abstract void waitForDataNodeToStart(ServerName serverName, long timeout) @@ -220,7 +214,6 @@ public abstract class HBaseCluster implements Closeable, Configurable { /** * Wait for the specified datanode to stop the thread / process. - * @return whether the operation finished with success * @throws IOException if something goes wrong or timeout occurs */ public abstract void waitForDataNodeToStop(ServerName serverName, long timeout) @@ -248,7 +241,6 @@ public abstract class HBaseCluster implements Closeable, Configurable { /** * Wait for the specified namenode to join the cluster - * @return whether the operation finished with success * @throws IOException if something goes wrong or timeout occurs */ public abstract void waitForNameNodeToStart(ServerName serverName, long timeout) @@ -256,7 +248,6 @@ public abstract class HBaseCluster implements Closeable, Configurable { /** * Wait for the specified namenode to stop - * @return whether the operation finished with success * @throws IOException if something goes wrong or timeout occurs */ public abstract void waitForNameNodeToStop(ServerName serverName, long timeout) @@ -266,7 +257,6 @@ public abstract class HBaseCluster implements Closeable, Configurable { * Starts a new master on the given hostname or if this is a mini/local cluster, * starts a master locally. * @param hostname the hostname to start the master on - * @return whether the operation finished with success * @throws IOException if something goes wrong */ public abstract void startMaster(String hostname, int port) throws IOException; diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java index f7906308229..eea0c67b268 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/HBaseTestingUtility.java @@ -3700,7 +3700,7 @@ public class HBaseTestingUtility extends HBaseZKTestingUtility { * @param startKey * @param endKey * @param numRegions the number of regions to be created. it has to be greater than 3. - * @return + * @return resulting split keys */ public byte[][] getRegionSplitStartKeys(byte[] startKey, byte[] endKey, int numRegions){ assertTrue(numRegions>3); diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/TestServerSideScanMetricsFromClientSide.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/TestServerSideScanMetricsFromClientSide.java index 906d4586371..64ef07a784a 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/TestServerSideScanMetricsFromClientSide.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/TestServerSideScanMetricsFromClientSide.java @@ -109,6 +109,12 @@ public class TestServerSideScanMetricsFromClientSide { /** * Make puts to put the input value into each combination of row, family, and qualifier + * @param rows the rows to use + * @param families the column families to use + * @param qualifiers the column qualifiers to use + * @param value the value to put + * @return the putted input values added in puts + * @throws IOException If an IO problem is encountered */ private static ArrayList createPuts(byte[][] rows, byte[][] families, byte[][] qualifiers, byte[] value) throws IOException { @@ -133,6 +139,7 @@ public class TestServerSideScanMetricsFromClientSide { * @return The approximate heap size of a cell in the test table. All cells should have * approximately the same heap size, so the value is cached to avoid repeating the * calculation + * @throws Exception on unexpected failure */ private long getCellHeapSize() throws Exception { if (CELL_HEAP_SIZE == -1) { @@ -309,7 +316,11 @@ public class TestServerSideScanMetricsFromClientSide { } /** - * Run the scan to completion and check the metric against the specified value + * Run the scan to completetion and check the metric against the specified value + * @param scan The scan instance to use to record metrics + * @param metricKey The metric key name + * @param expectedValue The expected value of metric + * @throws Exception on unexpected failure */ private void testMetric(Scan scan, String metricKey, long expectedValue) throws Exception { assertTrue("Scan should be configured to record metrics", scan.isScanMetricsEnabled()); diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestOpenTableInCoprocessor.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestOpenTableInCoprocessor.java index 80b0894ca7f..860a86b1e5a 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestOpenTableInCoprocessor.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestOpenTableInCoprocessor.java @@ -94,9 +94,8 @@ public class TestOpenTableInCoprocessor { public static class CustomThreadPoolCoprocessor implements RegionCoprocessor, RegionObserver { /** - * Get a pool that has only ever one thread. A second action added to the pool (running - * concurrently), will cause an exception. - * @return + * @return a pool that has one thread only at every time. A second action added to the pool ( + * running concurrently), will cause an exception. */ private ExecutorService getPool() { int maxThreads = 1; diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/RandomKeyValueUtil.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/RandomKeyValueUtil.java index 337a32ff513..552b0849f22 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/RandomKeyValueUtil.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/RandomKeyValueUtil.java @@ -79,10 +79,9 @@ public class RandomKeyValueUtil { * increases. The result consists of a prefix, which is a deterministic * increasing function of i, and a random suffix. * - * @param rand - * random number generator to use + * @param rand random number generator to use * @param i - * @return + * @return the random key */ public static byte[] randomOrderedKey(Random rand, int i) { StringBuilder k = new StringBuilder(); diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestRegionPlacement.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestRegionPlacement.java index f1ff63f4afb..37f50202779 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestRegionPlacement.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestRegionPlacement.java @@ -301,7 +301,7 @@ public class TestRegionPlacement { * @param plan The assignment plan * @param p1 The first switch position * @param p2 The second switch position - * @return + * @return the shuffled assignment plan */ private FavoredNodesPlan shuffleAssignmentPlan(FavoredNodesPlan plan, FavoredNodesPlan.Position p1, FavoredNodesPlan.Position p2) throws IOException { diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/balancer/BalancerTestBase.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/balancer/BalancerTestBase.java index 329d7a17863..6a3aaee5f5e 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/balancer/BalancerTestBase.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/balancer/BalancerTestBase.java @@ -328,7 +328,7 @@ public class BalancerTestBase { * * @param list * @param plans - * @return + * @return a list of all added {@link ServerAndLoad} values. */ protected List reconcile(List list, List plans, diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHStore.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHStore.java index e1e74f4d993..21043491e00 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHStore.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHStore.java @@ -794,7 +794,7 @@ public class TestHStore { * @param numRows * @param qualifier * @param family - * @return + * @return the rows key-value list */ List getKeyValueSet(long[] timestamps, int numRows, byte[] qualifier, byte[] family) { diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHStoreFile.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHStoreFile.java index ac63974098a..77de366cf3f 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHStoreFile.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHStoreFile.java @@ -844,7 +844,7 @@ public class TestHStoreFile extends HBaseTestCase { * @param numRows * @param qualifier * @param family - * @return + * @return the rows key-value list */ List getKeyValueSet(long[] timestamps, int numRows, byte[] qualifier, byte[] family) { diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMobStoreScanner.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMobStoreScanner.java index bcbc525ef77..faae36aa74f 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMobStoreScanner.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMobStoreScanner.java @@ -130,7 +130,6 @@ public class TestMobStoreScanner { * * @param reversed if true, scan will be backward order * @param mobScanRaw if true, scan will get the mob reference - * @return this */ public void setScan(Scan scan, boolean reversed, boolean mobScanRaw) { scan.setReversed(reversed); diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/MultiThreadedAction.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/MultiThreadedAction.java index 681499cdd36..1b8f2ed2b37 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/MultiThreadedAction.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/MultiThreadedAction.java @@ -320,7 +320,8 @@ public abstract class MultiThreadedAction { * @param verifyCfAndColumnIntegrity verify that cf/column set in the result is complete. Note * that to use this multiPut should be used, or verification * has to happen after writes, otherwise there can be races. - * @return + * @return true if the values of row result makes sense for row/cf/column combination and true if + * the cf/column set in the result is complete, false otherwise. */ public boolean verifyResultAgainstDataGenerator(Result result, boolean verifyValues, boolean verifyCfAndColumnIntegrity) { diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/test/LoadTestDataGenerator.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/test/LoadTestDataGenerator.java index 1aab1f8231d..089a181cb8d 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/util/test/LoadTestDataGenerator.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/util/test/LoadTestDataGenerator.java @@ -165,8 +165,7 @@ public abstract class LoadTestDataGenerator { } /** - * Return the arguments passed to the generator as list of object - * @return + * @return the arguments passed to the generator as a list of objects. */ public String[] getArgs() { return this.args; diff --git a/hbase-zookeeper/src/main/java/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.java b/hbase-zookeeper/src/main/java/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.java index b158bb7f348..a6cf9f43811 100644 --- a/hbase-zookeeper/src/main/java/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.java +++ b/hbase-zookeeper/src/main/java/org/apache/hadoop/hbase/zookeeper/MiniZooKeeperCluster.java @@ -126,7 +126,7 @@ public class MiniZooKeeperCluster { * Selects a ZK client port. * * @param seedPort the seed port to start with; -1 means first time. - * @Returns a valid and unused client port + * @return a valid and unused client port */ private int selectClientPort(int seedPort) { int i;