HBASE-22571 Javadoc Warnings related to @return tag
Signed-off-by: Jan Hentschel <jan.hentschel@ultratendency.com>
This commit is contained in:
parent
12d7db7078
commit
9f343c2efa
|
@ -433,7 +433,7 @@ class SimpleRequestController implements RequestController {
|
||||||
*
|
*
|
||||||
* @param loc
|
* @param loc
|
||||||
* @param heapSizeOfRow
|
* @param heapSizeOfRow
|
||||||
* @return
|
* @return either Include {@link ReturnCode} or Skip {@link ReturnCode}
|
||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
||||||
public ReturnCode canTakeOperation(HRegionLocation loc, long heapSizeOfRow) {
|
public ReturnCode canTakeOperation(HRegionLocation loc, long heapSizeOfRow) {
|
||||||
|
|
|
@ -143,11 +143,11 @@ public class TestTableInputFormat {
|
||||||
/**
|
/**
|
||||||
* Verify that the result and key have expected values.
|
* Verify that the result and key have expected values.
|
||||||
*
|
*
|
||||||
* @param r
|
* @param r single row result
|
||||||
* @param key
|
* @param key the row key
|
||||||
* @param expectedKey
|
* @param expectedKey the expected key
|
||||||
* @param expectedValue
|
* @param expectedValue the expected value
|
||||||
* @return
|
* @return true if the result contains the expected key and value, false otherwise.
|
||||||
*/
|
*/
|
||||||
static boolean checkResult(Result r, ImmutableBytesWritable key,
|
static boolean checkResult(Result r, ImmutableBytesWritable key,
|
||||||
byte[] expectedKey, byte[] expectedValue) {
|
byte[] expectedKey, byte[] expectedValue) {
|
||||||
|
|
|
@ -141,11 +141,11 @@ public class TestTableInputFormat {
|
||||||
/**
|
/**
|
||||||
* Verify that the result and key have expected values.
|
* Verify that the result and key have expected values.
|
||||||
*
|
*
|
||||||
* @param r
|
* @param r single row result
|
||||||
* @param key
|
* @param key the row key
|
||||||
* @param expectedKey
|
* @param expectedKey the expected key
|
||||||
* @param expectedValue
|
* @param expectedValue the expected value
|
||||||
* @return
|
* @return true if the result contains the expected key and value, false otherwise.
|
||||||
*/
|
*/
|
||||||
static boolean checkResult(Result r, ImmutableBytesWritable key,
|
static boolean checkResult(Result r, ImmutableBytesWritable key,
|
||||||
byte[] expectedKey, byte[] expectedValue) {
|
byte[] expectedKey, byte[] expectedValue) {
|
||||||
|
|
|
@ -149,7 +149,7 @@ public final class VersionInfoUtil {
|
||||||
/**
|
/**
|
||||||
* Returns the version components
|
* Returns the version components
|
||||||
* Examples: "1.4.3" returns [1, 4, 3], "4.5.6-SNAPSHOT" returns [4, 5, 6, "SNAPSHOT"]
|
* 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) {
|
private static String[] getVersionComponents(final HBaseProtos.VersionInfo versionInfo) {
|
||||||
return versionInfo.getVersion().split("[\\.-]");
|
return versionInfo.getVersion().split("[\\.-]");
|
||||||
|
|
|
@ -218,8 +218,7 @@ public class EntityLock {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Shutdown the thread cleanly, quietly. We done.
|
* @return Shuts down the thread clean and quietly.
|
||||||
* @return
|
|
||||||
*/
|
*/
|
||||||
Thread shutdown() {
|
Thread shutdown() {
|
||||||
shutdown = true;
|
shutdown = true;
|
||||||
|
|
|
@ -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)}
|
* 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.
|
* In here we also handle replay of edits on region recover. Also gets change in size brought
|
||||||
* @return Change in size brought about by applying <code>batchOp</code>
|
* about by applying {@code batchOp}.
|
||||||
*/
|
*/
|
||||||
private void doMiniBatchMutate(BatchOperation<?> batchOp) throws IOException {
|
private void doMiniBatchMutate(BatchOperation<?> batchOp) throws IOException {
|
||||||
boolean success = false;
|
boolean success = false;
|
||||||
|
|
|
@ -300,7 +300,6 @@ public class MemStoreLABImpl implements MemStoreLAB {
|
||||||
* <code>c</code>. Postcondition is that curChunk.get()
|
* <code>c</code>. Postcondition is that curChunk.get()
|
||||||
* != c
|
* != c
|
||||||
* @param c the chunk to retire
|
* @param c the chunk to retire
|
||||||
* @return true if we won the race to retire the chunk
|
|
||||||
*/
|
*/
|
||||||
private void tryRetireChunk(Chunk c) {
|
private void tryRetireChunk(Chunk c) {
|
||||||
currChunk.compareAndSet(c, null);
|
currChunk.compareAndSet(c, null);
|
||||||
|
|
|
@ -539,7 +539,7 @@ public class RSRpcServices implements HBaseRPCErrorHandler,
|
||||||
* Starts the nonce operation for a mutation, if needed.
|
* Starts the nonce operation for a mutation, if needed.
|
||||||
* @param mutation Mutation.
|
* @param mutation Mutation.
|
||||||
* @param nonceGroup Nonce group from the request.
|
* @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)
|
private boolean startNonceOperation(final MutationProto mutation, long nonceGroup)
|
||||||
throws IOException {
|
throws IOException {
|
||||||
|
|
|
@ -614,7 +614,6 @@ public final class SnapshotInfo extends AbstractHBaseTool {
|
||||||
* @param uniqueHFilesArchiveSize {@link AtomicLong} the accumulated store file size in archive
|
* @param uniqueHFilesArchiveSize {@link AtomicLong} the accumulated store file size in archive
|
||||||
* @param uniqueHFilesSize {@link AtomicLong} the accumulated store file size shared
|
* @param uniqueHFilesSize {@link AtomicLong} the accumulated store file size shared
|
||||||
* @param uniqueHFilesMobSize {@link AtomicLong} the accumulated mob 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,
|
private static void getSnapshotFilesMap(final Configuration conf,
|
||||||
final SnapshotDescription snapshot, final ExecutorService exec,
|
final SnapshotDescription snapshot, final ExecutorService exec,
|
||||||
|
|
|
@ -118,14 +118,12 @@ public abstract class HBaseCluster implements Closeable, Configurable {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Stops the given region server, by attempting a gradual stop.
|
* Stops the given region server, by attempting a gradual stop.
|
||||||
* @return whether the operation finished with success
|
|
||||||
* @throws IOException if something goes wrong
|
* @throws IOException if something goes wrong
|
||||||
*/
|
*/
|
||||||
public abstract void stopRegionServer(ServerName serverName) throws IOException;
|
public abstract void stopRegionServer(ServerName serverName) throws IOException;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Wait for the specified region server to join the cluster
|
* 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
|
* @throws IOException if something goes wrong or timeout occurs
|
||||||
*/
|
*/
|
||||||
public void waitForRegionServerToStart(String hostname, int port, long timeout)
|
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.
|
* 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
|
* @throws IOException if something goes wrong or timeout occurs
|
||||||
*/
|
*/
|
||||||
public abstract void waitForRegionServerToStop(ServerName serverName, long timeout)
|
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
|
* 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
|
* @throws IOException if something goes wrong or timeout occurs
|
||||||
*/
|
*/
|
||||||
public abstract void waitForZkNodeToStart(ServerName serverName, long timeout)
|
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.
|
* 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
|
* @throws IOException if something goes wrong or timeout occurs
|
||||||
*/
|
*/
|
||||||
public abstract void waitForZkNodeToStop(ServerName serverName, long timeout)
|
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
|
* 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
|
* @throws IOException if something goes wrong or timeout occurs
|
||||||
*/
|
*/
|
||||||
public abstract void waitForDataNodeToStart(ServerName serverName, long timeout)
|
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.
|
* 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
|
* @throws IOException if something goes wrong or timeout occurs
|
||||||
*/
|
*/
|
||||||
public abstract void waitForDataNodeToStop(ServerName serverName, long timeout)
|
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
|
* 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
|
* @throws IOException if something goes wrong or timeout occurs
|
||||||
*/
|
*/
|
||||||
public abstract void waitForNameNodeToStart(ServerName serverName, long timeout)
|
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
|
* Wait for the specified namenode to stop
|
||||||
* @return whether the operation finished with success
|
|
||||||
* @throws IOException if something goes wrong or timeout occurs
|
* @throws IOException if something goes wrong or timeout occurs
|
||||||
*/
|
*/
|
||||||
public abstract void waitForNameNodeToStop(ServerName serverName, long timeout)
|
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 new master on the given hostname or if this is a mini/local cluster,
|
||||||
* starts a master locally.
|
* starts a master locally.
|
||||||
* @param hostname the hostname to start the master on
|
* @param hostname the hostname to start the master on
|
||||||
* @return whether the operation finished with success
|
|
||||||
* @throws IOException if something goes wrong
|
* @throws IOException if something goes wrong
|
||||||
*/
|
*/
|
||||||
public abstract void startMaster(String hostname, int port) throws IOException;
|
public abstract void startMaster(String hostname, int port) throws IOException;
|
||||||
|
|
|
@ -3700,7 +3700,7 @@ public class HBaseTestingUtility extends HBaseZKTestingUtility {
|
||||||
* @param startKey
|
* @param startKey
|
||||||
* @param endKey
|
* @param endKey
|
||||||
* @param numRegions the number of regions to be created. it has to be greater than 3.
|
* @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){
|
public byte[][] getRegionSplitStartKeys(byte[] startKey, byte[] endKey, int numRegions){
|
||||||
assertTrue(numRegions>3);
|
assertTrue(numRegions>3);
|
||||||
|
|
|
@ -109,6 +109,12 @@ public class TestServerSideScanMetricsFromClientSide {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Make puts to put the input value into each combination of row, family, and qualifier
|
* 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<Put> createPuts(byte[][] rows, byte[][] families, byte[][] qualifiers,
|
private static ArrayList<Put> createPuts(byte[][] rows, byte[][] families, byte[][] qualifiers,
|
||||||
byte[] value) throws IOException {
|
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
|
* @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
|
* approximately the same heap size, so the value is cached to avoid repeating the
|
||||||
* calculation
|
* calculation
|
||||||
|
* @throws Exception on unexpected failure
|
||||||
*/
|
*/
|
||||||
private long getCellHeapSize() throws Exception {
|
private long getCellHeapSize() throws Exception {
|
||||||
if (CELL_HEAP_SIZE == -1) {
|
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 {
|
private void testMetric(Scan scan, String metricKey, long expectedValue) throws Exception {
|
||||||
assertTrue("Scan should be configured to record metrics", scan.isScanMetricsEnabled());
|
assertTrue("Scan should be configured to record metrics", scan.isScanMetricsEnabled());
|
||||||
|
|
|
@ -94,9 +94,8 @@ public class TestOpenTableInCoprocessor {
|
||||||
public static class CustomThreadPoolCoprocessor implements RegionCoprocessor, RegionObserver {
|
public static class CustomThreadPoolCoprocessor implements RegionCoprocessor, RegionObserver {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Get a pool that has only ever one thread. A second action added to the pool (running
|
* @return a pool that has one thread only at every time. A second action added to the pool (
|
||||||
* concurrently), will cause an exception.
|
* running concurrently), will cause an exception.
|
||||||
* @return
|
|
||||||
*/
|
*/
|
||||||
private ExecutorService getPool() {
|
private ExecutorService getPool() {
|
||||||
int maxThreads = 1;
|
int maxThreads = 1;
|
||||||
|
|
|
@ -79,10 +79,9 @@ public class RandomKeyValueUtil {
|
||||||
* increases. The result consists of a prefix, which is a deterministic
|
* increases. The result consists of a prefix, which is a deterministic
|
||||||
* increasing function of i, and a random suffix.
|
* increasing function of i, and a random suffix.
|
||||||
*
|
*
|
||||||
* @param rand
|
* @param rand random number generator to use
|
||||||
* random number generator to use
|
|
||||||
* @param i
|
* @param i
|
||||||
* @return
|
* @return the random key
|
||||||
*/
|
*/
|
||||||
public static byte[] randomOrderedKey(Random rand, int i) {
|
public static byte[] randomOrderedKey(Random rand, int i) {
|
||||||
StringBuilder k = new StringBuilder();
|
StringBuilder k = new StringBuilder();
|
||||||
|
|
|
@ -301,7 +301,7 @@ public class TestRegionPlacement {
|
||||||
* @param plan The assignment plan
|
* @param plan The assignment plan
|
||||||
* @param p1 The first switch position
|
* @param p1 The first switch position
|
||||||
* @param p2 The second switch position
|
* @param p2 The second switch position
|
||||||
* @return
|
* @return the shuffled assignment plan
|
||||||
*/
|
*/
|
||||||
private FavoredNodesPlan shuffleAssignmentPlan(FavoredNodesPlan plan,
|
private FavoredNodesPlan shuffleAssignmentPlan(FavoredNodesPlan plan,
|
||||||
FavoredNodesPlan.Position p1, FavoredNodesPlan.Position p2) throws IOException {
|
FavoredNodesPlan.Position p1, FavoredNodesPlan.Position p2) throws IOException {
|
||||||
|
|
|
@ -328,7 +328,7 @@ public class BalancerTestBase {
|
||||||
*
|
*
|
||||||
* @param list
|
* @param list
|
||||||
* @param plans
|
* @param plans
|
||||||
* @return
|
* @return a list of all added {@link ServerAndLoad} values.
|
||||||
*/
|
*/
|
||||||
protected List<ServerAndLoad> reconcile(List<ServerAndLoad> list,
|
protected List<ServerAndLoad> reconcile(List<ServerAndLoad> list,
|
||||||
List<RegionPlan> plans,
|
List<RegionPlan> plans,
|
||||||
|
|
|
@ -794,7 +794,7 @@ public class TestHStore {
|
||||||
* @param numRows
|
* @param numRows
|
||||||
* @param qualifier
|
* @param qualifier
|
||||||
* @param family
|
* @param family
|
||||||
* @return
|
* @return the rows key-value list
|
||||||
*/
|
*/
|
||||||
List<Cell> getKeyValueSet(long[] timestamps, int numRows,
|
List<Cell> getKeyValueSet(long[] timestamps, int numRows,
|
||||||
byte[] qualifier, byte[] family) {
|
byte[] qualifier, byte[] family) {
|
||||||
|
|
|
@ -844,7 +844,7 @@ public class TestHStoreFile extends HBaseTestCase {
|
||||||
* @param numRows
|
* @param numRows
|
||||||
* @param qualifier
|
* @param qualifier
|
||||||
* @param family
|
* @param family
|
||||||
* @return
|
* @return the rows key-value list
|
||||||
*/
|
*/
|
||||||
List<KeyValue> getKeyValueSet(long[] timestamps, int numRows,
|
List<KeyValue> getKeyValueSet(long[] timestamps, int numRows,
|
||||||
byte[] qualifier, byte[] family) {
|
byte[] qualifier, byte[] family) {
|
||||||
|
|
|
@ -130,7 +130,6 @@ public class TestMobStoreScanner {
|
||||||
*
|
*
|
||||||
* @param reversed if true, scan will be backward order
|
* @param reversed if true, scan will be backward order
|
||||||
* @param mobScanRaw if true, scan will get the mob reference
|
* @param mobScanRaw if true, scan will get the mob reference
|
||||||
* @return this
|
|
||||||
*/
|
*/
|
||||||
public void setScan(Scan scan, boolean reversed, boolean mobScanRaw) {
|
public void setScan(Scan scan, boolean reversed, boolean mobScanRaw) {
|
||||||
scan.setReversed(reversed);
|
scan.setReversed(reversed);
|
||||||
|
|
|
@ -320,7 +320,8 @@ public abstract class MultiThreadedAction {
|
||||||
* @param verifyCfAndColumnIntegrity verify that cf/column set in the result is complete. Note
|
* @param verifyCfAndColumnIntegrity verify that cf/column set in the result is complete. Note
|
||||||
* that to use this multiPut should be used, or verification
|
* that to use this multiPut should be used, or verification
|
||||||
* has to happen after writes, otherwise there can be races.
|
* 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,
|
public boolean verifyResultAgainstDataGenerator(Result result, boolean verifyValues,
|
||||||
boolean verifyCfAndColumnIntegrity) {
|
boolean verifyCfAndColumnIntegrity) {
|
||||||
|
|
|
@ -165,8 +165,7 @@ public abstract class LoadTestDataGenerator {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Return the arguments passed to the generator as list of object
|
* @return the arguments passed to the generator as a list of objects.
|
||||||
* @return
|
|
||||||
*/
|
*/
|
||||||
public String[] getArgs() {
|
public String[] getArgs() {
|
||||||
return this.args;
|
return this.args;
|
||||||
|
|
|
@ -126,7 +126,7 @@ public class MiniZooKeeperCluster {
|
||||||
* Selects a ZK client port.
|
* Selects a ZK client port.
|
||||||
*
|
*
|
||||||
* @param seedPort the seed port to start with; -1 means first time.
|
* @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) {
|
private int selectClientPort(int seedPort) {
|
||||||
int i;
|
int i;
|
||||||
|
|
Loading…
Reference in New Issue