HBASE-19538 Removed unnecessary semicolons in hbase-client

This commit is contained in:
Jan Hentschel 2017-12-17 16:15:20 +01:00
parent 606ff3357d
commit d111b17c36
9 changed files with 12 additions and 11 deletions

View File

@ -483,6 +483,6 @@ public class ClusterStatus {
BACKUP_MASTERS, /** status about backup masters */ BACKUP_MASTERS, /** status about backup masters */
MASTER_COPROCESSORS, /** status about master coprocessors */ MASTER_COPROCESSORS, /** status about master coprocessors */
REGIONS_IN_TRANSITION, /** status about regions in transition */ REGIONS_IN_TRANSITION, /** status about regions in transition */
MASTER_INFO_PORT; /** master info port **/ MASTER_INFO_PORT /** master info port **/
} }
} }

View File

@ -332,7 +332,7 @@ public class MetaTableAccessor {
parsedInfo = parseRegionInfoFromRegionName(regionName); parsedInfo = parseRegionInfoFromRegionName(regionName);
row = getMetaKeyForRegion(parsedInfo); row = getMetaKeyForRegion(parsedInfo);
} catch (Exception parseEx) { } catch (Exception parseEx) {
; // Ignore. This is used with tableName passed as regionName. // Ignore. This is used with tableName passed as regionName.
} }
Get get = new Get(row); Get get = new Get(row);
get.addFamily(HConstants.CATALOG_FAMILY); get.addFamily(HConstants.CATALOG_FAMILY);

View File

@ -16,6 +16,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.apache.hadoop.hbase.client; package org.apache.hadoop.hbase.client;
import org.apache.yetus.audience.InterfaceAudience; import org.apache.yetus.audience.InterfaceAudience;
/** /**
@ -23,5 +24,5 @@ import org.apache.yetus.audience.InterfaceAudience;
*/ */
@InterfaceAudience.Public @InterfaceAudience.Public
public enum CompactionState { public enum CompactionState {
NONE, MINOR, MAJOR, MAJOR_AND_MINOR; NONE, MINOR, MAJOR, MAJOR_AND_MINOR
} }

View File

@ -3082,7 +3082,7 @@ public class HBaseAdmin implements Admin {
CoprocessorRpcUtils.getCoprocessorServiceRequest(method, request); CoprocessorRpcUtils.getCoprocessorServiceRequest(method, request);
return this.master.execMasterService(getRpcController(), csr); return this.master.execMasterService(getRpcController(), csr);
} }
};) { }) {
// TODO: Are we retrying here? Does not seem so. We should use RetryingRpcCaller // TODO: Are we retrying here? Does not seem so. We should use RetryingRpcCaller
callable.prepare(false); callable.prepare(false);
int operationTimeout = connection.getConnectionConfiguration().getOperationTimeout(); int operationTimeout = connection.getConnectionConfiguration().getOperationTimeout();
@ -3619,7 +3619,7 @@ public class HBaseAdmin implements Admin {
return "Operation: " + getOperationType() + ", " return "Operation: " + getOperationType() + ", "
+ "Table Name: " + tableName.getNameWithNamespaceInclAsString(); + "Table Name: " + tableName.getNameWithNamespaceInclAsString();
}; }
protected abstract class TableWaitForStateCallable implements WaitForStateCallable { protected abstract class TableWaitForStateCallable implements WaitForStateCallable {
@Override @Override

View File

@ -16,6 +16,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.apache.hadoop.hbase.client; package org.apache.hadoop.hbase.client;
import org.apache.yetus.audience.InterfaceAudience; import org.apache.yetus.audience.InterfaceAudience;
/** /**
@ -23,5 +24,5 @@ import org.apache.yetus.audience.InterfaceAudience;
*/ */
@InterfaceAudience.Public @InterfaceAudience.Public
public enum SnapshotType { public enum SnapshotType {
DISABLED, FLUSH, SKIPFLUSH; DISABLED, FLUSH, SKIPFLUSH
} }

View File

@ -57,5 +57,4 @@ public enum SecurityCapability {
throw new IllegalArgumentException("Unknown SecurityCapability value " + value); throw new IllegalArgumentException("Unknown SecurityCapability value " + value);
} }
} }
}; }

View File

@ -41,5 +41,5 @@ public enum SpaceViolationPolicy {
/** /**
* Disallows any updates (but allows deletes and compactions) on the table(s). * Disallows any updates (but allows deletes and compactions) on the table(s).
*/ */
NO_INSERTS; NO_INSERTS
} }

View File

@ -67,7 +67,7 @@ public class ThrottlingException extends QuotaExceededException {
int index = msg.indexOf(MSG_TYPE[i]); int index = msg.indexOf(MSG_TYPE[i]);
if (index >= 0) { if (index >= 0) {
String waitTimeStr = msg.substring(index + MSG_TYPE[i].length() + MSG_WAIT.length()); String waitTimeStr = msg.substring(index + MSG_TYPE[i].length() + MSG_WAIT.length());
type = Type.values()[i];; type = Type.values()[i];
waitInterval = timeFromString(waitTimeStr); waitInterval = timeFromString(waitTimeStr);
break; break;
} }

View File

@ -659,7 +659,7 @@ public class TestAsyncProcess {
MyAsyncProcess ap = new MyAsyncProcess(conn, CONF, true); MyAsyncProcess ap = new MyAsyncProcess(conn, CONF, true);
BufferedMutatorParams bufferParam = createBufferedMutatorParams(ap, DUMMY_TABLE); BufferedMutatorParams bufferParam = createBufferedMutatorParams(ap, DUMMY_TABLE);
try (BufferedMutatorImpl mutator = new BufferedMutatorImpl(conn, bufferParam, ap);) { try (BufferedMutatorImpl mutator = new BufferedMutatorImpl(conn, bufferParam, ap)) {
mutator.mutate(puts); mutator.mutate(puts);
mutator.flush(); mutator.flush();
List<AsyncRequestFuture> reqs = ap.allReqs; List<AsyncRequestFuture> reqs = ap.allReqs;