[21/30] hbase-site git commit: Published site at 931156f66b1decc19d89f8bb3ce9e5f355fb4fb2.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6b8b907f/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.KeepAliveWorkerThread.html
--
diff --git
a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.KeepAliveWorkerThread.html
b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.KeepAliveWorkerThread.html
index 688bd4e..37bf508 100644
---
a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.KeepAliveWorkerThread.html
+++
b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureExecutor.KeepAliveWorkerThread.html
@@ -589,1651 +589,1649 @@
581 LOG.debug("Loading {}", proc);
582
583 Long rootProcId =
getRootProcedureId(proc);
-584 if (rootProcId == null) {
-585// The 'proc' was ready to run
but the root procedure was rolledback?
-586scheduler.addBack(proc);
-587continue;
-588 }
-589
-590 if (proc.hasParent()) {
-591ProcedureTEnvironment
parent = procedures.get(proc.getParentProcId());
-592// corrupted procedures are
handled later at step 3
-593if (parent != null
!proc.isFinished()) {
-594 parent.incChildrenLatch();
-595}
-596 }
-597
-598
RootProcedureStateTEnvironment procStack =
rollbackStack.get(rootProcId);
-599 procStack.loadStack(proc);
-600
-601 proc.setRootProcId(rootProcId);
-602 switch (proc.getState()) {
-603case RUNNABLE:
-604 runnableList.add(proc);
-605 break;
-606case WAITING:
-607 waitingList.add(proc);
-608 break;
-609case WAITING_TIMEOUT:
-610 waitingTimeoutList.add(proc);
-611 break;
-612case FAILED:
-613 failedList.add(proc);
-614 break;
-615case ROLLEDBACK:
-616case INITIALIZING:
-617 String msg = "Unexpected " +
proc.getState() + " state for " + proc;
-618 LOG.error(msg);
-619 throw new
UnsupportedOperationException(msg);
-620default:
-621 break;
-622 }
-623}
-624
-625// 4. Check the waiting procedures to
see if some of them can be added to runnable.
-626waitingList.forEach(proc - {
-627 if (!proc.hasChildren()) {
-628// Normally, WAITING procedures
should be waken by its children.
-629// But, there is a case that, all
the children are successful and before
-630// they can wake up their parent
procedure, the master was killed.
-631// So, during recovering the
procedures from ProcedureWal, its children
-632// are not loaded because of
their SUCCESS state.
-633// So we need to continue to run
this WAITING procedure. But before
-634// executing, we need to set its
state to RUNNABLE, otherwise, a exception
-635// will throw:
-636//
Preconditions.checkArgument(procedure.getState() == ProcedureState.RUNNABLE,
-637// "NOT RUNNABLE! " +
procedure.toString());
-638
proc.setState(ProcedureState.RUNNABLE);
-639runnableList.add(proc);
-640 }
-641});
-642
-643// 5. Push the procedures to the
timeout executor
-644waitingTimeoutList.forEach(proc -
{
-645
proc.afterReplay(getEnvironment());
-646 timeoutExecutor.add(proc);
-647});
-648// 6. restore locks
-649restoreLocks();
-650// 7. Push the procedure to the
scheduler
-651
failedList.forEach(scheduler::addBack);
-652runnableList.forEach(p - {
-653 p.afterReplay(getEnvironment());
-654 if (!p.hasParent()) {
-655
sendProcedureLoadedNotification(p.getProcId());
-656 }
-657 scheduler.addBack(p);
-658});
-659 }
-660
-661 /**
-662 * Initialize the procedure executor,
but do not start workers. We will start them later.
-663 * p/
-664 * It calls
ProcedureStore.recoverLease() and ProcedureStore.load() to recover the lease,
and
-665 * ensure a single executor, and start
the procedure replay to resume and recover the previous
-666 * pending and in-progress
procedures.
-667 * @param numThreads number of threads
available for procedure execution.
-668 * @param abortOnCorruption true if you
want to abort your service in case a corrupted procedure
-669 * is found on replay.
otherwise false.
-670 */
-671 public void init(int numThreads,
boolean abortOnCorruption) throws IOException {
-672// We have numThreads executor + one
timer thread used for timing out
-673// procedures and triggering periodic
procedures.
-674this.corePoolSize = numThreads;
-675this.maxPoolSize = 10 * numThreads;
-676LOG.info("Starting {} core workers
(bigger of cpus/4 or 16) with max (burst) worker count={}",
-677corePoolSize, maxPoolSize);
-678
-679this.threadGroup = new
ThreadGroup("PEWorkerGroup");
-680this.timeoutExecutor = new
[21/30] hbase-site git commit: Published site at a8e184dc77470bdf9d62e19c5d36bc1de7cf4c6d.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5fd895c6/checkstyle.rss -- diff --git a/checkstyle.rss b/checkstyle.rss index 8ec744e..8fa3078 100644 --- a/checkstyle.rss +++ b/checkstyle.rss @@ -26,7 +26,7 @@ under the License. 2007 - 2018 The Apache Software Foundation File: 3697, - Errors: 15629, + Errors: 15627, Warnings: 0, Infos: 0 @@ -29777,7 +29777,7 @@ under the License. 0 - 2 + 0 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5fd895c6/coc.html -- diff --git a/coc.html b/coc.html index d0903ac..17ec608 100644 --- a/coc.html +++ b/coc.html @@ -7,7 +7,7 @@ - + Apache HBase Code of Conduct Policy @@ -375,7 +375,7 @@ email to mailto:priv...@hbase.apache.org;>the priv https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2018-07-30 + Last Published: 2018-07-31 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5fd895c6/dependencies.html -- diff --git a/dependencies.html b/dependencies.html index 2a9e916..e1706d9 100644 --- a/dependencies.html +++ b/dependencies.html @@ -7,7 +7,7 @@ - + Apache HBase Project Dependencies @@ -440,7 +440,7 @@ https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2018-07-30 + Last Published: 2018-07-31 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5fd895c6/dependency-convergence.html -- diff --git a/dependency-convergence.html b/dependency-convergence.html index 9748874..397fefc 100644 --- a/dependency-convergence.html +++ b/dependency-convergence.html @@ -7,7 +7,7 @@ - + Apache HBase Reactor Dependency Convergence @@ -905,7 +905,7 @@ https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2018-07-30 + Last Published: 2018-07-31 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5fd895c6/dependency-info.html -- diff --git a/dependency-info.html b/dependency-info.html index b7a769e..101ba34 100644 --- a/dependency-info.html +++ b/dependency-info.html @@ -7,7 +7,7 @@ - + Apache HBase Dependency Information @@ -313,7 +313,7 @@ https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2018-07-30 + Last Published: 2018-07-31 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5fd895c6/dependency-management.html -- diff --git a/dependency-management.html b/dependency-management.html index d94248e..a22cd86 100644 --- a/dependency-management.html +++ b/dependency-management.html @@ -7,7 +7,7 @@ - + Apache HBase Project Dependency Management @@ -1005,7 +1005,7 @@ https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2018-07-30 + Last Published: 2018-07-31 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/5fd895c6/devapidocs/constant-values.html -- diff --git a/devapidocs/constant-values.html b/devapidocs/constant-values.html index 200fe3f..27db464 100644 --- a/devapidocs/constant-values.html +++ b/devapidocs/constant-values.html @@ -116,6 +116,20 @@ GROUP_PREFIX "@" + + + +publicstaticfinalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String +HBASE_CLIENT_KERBEROS_PRINCIPAL +"hbase.client.keytab.principal" + + + + +publicstaticfinalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String +HBASE_CLIENT_KEYTAB_FILE
[21/30] hbase-site git commit: Published site at 59867eeeebd28fcc49f338ef36769fb6a9bff4dc.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/67e3bccd/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html b/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html index 89cf72c..7ab6815 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html @@ -704,20 +704,20 @@ java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.https://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.regionserver.HRegion.FlushResult.Result -org.apache.hadoop.hbase.regionserver.SplitLogWorker.TaskExecutor.Status -org.apache.hadoop.hbase.regionserver.TimeRangeTracker.Type -org.apache.hadoop.hbase.regionserver.ScannerContext.NextState -org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope org.apache.hadoop.hbase.regionserver.ScanType -org.apache.hadoop.hbase.regionserver.Region.Operation -org.apache.hadoop.hbase.regionserver.DefaultHeapMemoryTuner.StepDirection +org.apache.hadoop.hbase.regionserver.CompactingMemStore.IndexType +org.apache.hadoop.hbase.regionserver.MetricsRegionServerSourceFactoryImpl.FactoryStorage +org.apache.hadoop.hbase.regionserver.ChunkCreator.ChunkType org.apache.hadoop.hbase.regionserver.FlushType +org.apache.hadoop.hbase.regionserver.Region.Operation org.apache.hadoop.hbase.regionserver.MemStoreCompactionStrategy.Action -org.apache.hadoop.hbase.regionserver.ChunkCreator.ChunkType -org.apache.hadoop.hbase.regionserver.MetricsRegionServerSourceFactoryImpl.FactoryStorage -org.apache.hadoop.hbase.regionserver.CompactingMemStore.IndexType +org.apache.hadoop.hbase.regionserver.SplitLogWorker.TaskExecutor.Status +org.apache.hadoop.hbase.regionserver.TimeRangeTracker.Type +org.apache.hadoop.hbase.regionserver.HRegion.FlushResult.Result +org.apache.hadoop.hbase.regionserver.DefaultHeapMemoryTuner.StepDirection +org.apache.hadoop.hbase.regionserver.ScannerContext.NextState org.apache.hadoop.hbase.regionserver.BloomType +org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope http://git-wip-us.apache.org/repos/asf/hbase-site/blob/67e3bccd/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html b/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html index 858ccf6..3bd22b5 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html @@ -130,9 +130,9 @@ java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.https://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker.DeleteResult -org.apache.hadoop.hbase.regionserver.querymatcher.StripeCompactionScanQueryMatcher.DropDeletesInOutput org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher.MatchCode +org.apache.hadoop.hbase.regionserver.querymatcher.StripeCompactionScanQueryMatcher.DropDeletesInOutput +org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker.DeleteResult http://git-wip-us.apache.org/repos/asf/hbase-site/blob/67e3bccd/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html index e8df157..feee307 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html @@ -247,9 +247,9 @@ java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT,
[21/30] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/e80e3339/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.InitializationMonitor.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.InitializationMonitor.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.InitializationMonitor.html index ec25b93..62ed5ff 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.InitializationMonitor.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.InitializationMonitor.html @@ -60,3488 +60,3495 @@ 052import javax.servlet.http.HttpServlet; 053import javax.servlet.http.HttpServletRequest; 054import javax.servlet.http.HttpServletResponse; -055import org.apache.hadoop.conf.Configuration; -056import org.apache.hadoop.fs.Path; -057import org.apache.hadoop.hbase.ClusterId; -058import org.apache.hadoop.hbase.ClusterMetrics; -059import org.apache.hadoop.hbase.ClusterMetrics.Option; -060import org.apache.hadoop.hbase.ClusterMetricsBuilder; -061import org.apache.hadoop.hbase.CoordinatedStateException; -062import org.apache.hadoop.hbase.DoNotRetryIOException; -063import org.apache.hadoop.hbase.HBaseIOException; -064import org.apache.hadoop.hbase.HBaseInterfaceAudience; -065import org.apache.hadoop.hbase.HConstants; -066import org.apache.hadoop.hbase.InvalidFamilyOperationException; -067import org.apache.hadoop.hbase.MasterNotRunningException; -068import org.apache.hadoop.hbase.MetaTableAccessor; -069import org.apache.hadoop.hbase.NamespaceDescriptor; -070import org.apache.hadoop.hbase.PleaseHoldException; -071import org.apache.hadoop.hbase.ReplicationPeerNotFoundException; -072import org.apache.hadoop.hbase.ServerLoad; -073import org.apache.hadoop.hbase.ServerMetricsBuilder; -074import org.apache.hadoop.hbase.ServerName; -075import org.apache.hadoop.hbase.TableDescriptors; -076import org.apache.hadoop.hbase.TableName; -077import org.apache.hadoop.hbase.TableNotDisabledException; -078import org.apache.hadoop.hbase.TableNotFoundException; -079import org.apache.hadoop.hbase.UnknownRegionException; -080import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor; -081import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder; -082import org.apache.hadoop.hbase.client.MasterSwitchType; -083import org.apache.hadoop.hbase.client.RegionInfo; -084import org.apache.hadoop.hbase.client.Result; -085import org.apache.hadoop.hbase.client.TableDescriptor; -086import org.apache.hadoop.hbase.client.TableDescriptorBuilder; -087import org.apache.hadoop.hbase.client.TableState; -088import org.apache.hadoop.hbase.coprocessor.CoprocessorHost; -089import org.apache.hadoop.hbase.exceptions.DeserializationException; -090import org.apache.hadoop.hbase.exceptions.MergeRegionException; -091import org.apache.hadoop.hbase.executor.ExecutorType; -092import org.apache.hadoop.hbase.favored.FavoredNodesManager; -093import org.apache.hadoop.hbase.favored.FavoredNodesPromoter; -094import org.apache.hadoop.hbase.http.InfoServer; -095import org.apache.hadoop.hbase.ipc.CoprocessorRpcUtils; -096import org.apache.hadoop.hbase.ipc.RpcServer; -097import org.apache.hadoop.hbase.ipc.ServerNotRunningYetException; -098import org.apache.hadoop.hbase.log.HBaseMarkers; -099import org.apache.hadoop.hbase.master.MasterRpcServices.BalanceSwitchMode; -100import org.apache.hadoop.hbase.master.assignment.AssignmentManager; -101import org.apache.hadoop.hbase.master.assignment.MergeTableRegionsProcedure; -102import org.apache.hadoop.hbase.master.assignment.RegionStates; -103import org.apache.hadoop.hbase.master.assignment.RegionStates.RegionStateNode; -104import org.apache.hadoop.hbase.master.balancer.BalancerChore; -105import org.apache.hadoop.hbase.master.balancer.BaseLoadBalancer; -106import org.apache.hadoop.hbase.master.balancer.ClusterStatusChore; -107import org.apache.hadoop.hbase.master.balancer.LoadBalancerFactory; -108import org.apache.hadoop.hbase.master.cleaner.HFileCleaner; -109import org.apache.hadoop.hbase.master.cleaner.LogCleaner; -110import org.apache.hadoop.hbase.master.cleaner.ReplicationMetaCleaner; -111import org.apache.hadoop.hbase.master.locking.LockManager; -112import org.apache.hadoop.hbase.master.normalizer.NormalizationPlan; -113import org.apache.hadoop.hbase.master.normalizer.NormalizationPlan.PlanType; -114import org.apache.hadoop.hbase.master.normalizer.RegionNormalizer; -115import org.apache.hadoop.hbase.master.normalizer.RegionNormalizerChore; -116import org.apache.hadoop.hbase.master.normalizer.RegionNormalizerFactory; -117import org.apache.hadoop.hbase.master.procedure.CreateTableProcedure; -118import org.apache.hadoop.hbase.master.procedure.DeleteTableProcedure; -119import org.apache.hadoop.hbase.master.procedure.DisableTableProcedure; -120import org.apache.hadoop.hbase.master.procedure.EnableTableProcedure;
[21/30] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/dc5c2985/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html b/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html index 9d29552..313f199 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html @@ -130,9 +130,9 @@ java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher.MatchCode org.apache.hadoop.hbase.regionserver.querymatcher.StripeCompactionScanQueryMatcher.DropDeletesInOutput org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker.DeleteResult +org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher.MatchCode http://git-wip-us.apache.org/repos/asf/hbase-site/blob/dc5c2985/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html index 967570b..bcf514b 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html @@ -242,8 +242,8 @@ java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.regionserver.wal.RingBufferTruck.Type org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader.WALHdrResult +org.apache.hadoop.hbase.regionserver.wal.RingBufferTruck.Type http://git-wip-us.apache.org/repos/asf/hbase-site/blob/dc5c2985/devapidocs/org/apache/hadoop/hbase/replication/regionserver/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/package-tree.html b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/package-tree.html index d2095fe..f26658d 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/package-tree.html @@ -202,8 +202,8 @@ java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceShipper.WorkerState org.apache.hadoop.hbase.replication.regionserver.MetricsReplicationSourceFactoryImpl.SourceHolder +org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceShipper.WorkerState http://git-wip-us.apache.org/repos/asf/hbase-site/blob/dc5c2985/devapidocs/org/apache/hadoop/hbase/rest/model/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/rest/model/package-tree.html b/devapidocs/org/apache/hadoop/hbase/rest/model/package-tree.html index 91776e4..dc2f127 100644 --- a/devapidocs/org/apache/hadoop/hbase/rest/model/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/rest/model/package-tree.html @@ -110,8 +110,8 @@ java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable)
[21/30] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2bb8bd01/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.CoprocessOperationWithResult.html
--
diff --git
a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.CoprocessOperationWithResult.html
b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.CoprocessOperationWithResult.html
index 36f4c8d..ec36d2e 100644
---
a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.CoprocessOperationWithResult.html
+++
b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.CoprocessOperationWithResult.html
@@ -38,395 +38,326 @@
030import
org.apache.hadoop.hbase.Coprocessor;
031import
org.apache.hadoop.hbase.CoprocessorEnvironment;
032import
org.apache.hadoop.hbase.HBaseInterfaceAudience;
-033import
org.apache.hadoop.hbase.MetaMutationAnnotation;
-034import
org.apache.yetus.audience.InterfaceAudience;
-035import
org.apache.yetus.audience.InterfaceStability;
-036import
org.apache.hadoop.hbase.client.Mutation;
-037import
org.apache.hadoop.hbase.coprocessor.CoprocessorHost;
-038import
org.apache.hadoop.hbase.coprocessor.MetricsCoprocessor;
-039import
org.apache.hadoop.hbase.coprocessor.ObserverContext;
-040import
org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessorEnvironment;
-041import
org.apache.hadoop.hbase.coprocessor.RegionServerObserver;
-042import
org.apache.hadoop.hbase.coprocessor.SingletonCoprocessorService;
-043import
org.apache.hadoop.hbase.ipc.RpcServer;
-044import
org.apache.hadoop.hbase.metrics.MetricRegistry;
-045import
org.apache.hadoop.hbase.replication.ReplicationEndpoint;
-046import
org.apache.hadoop.hbase.security.User;
-047import
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry;
-048
-049@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.COPROC)
-050@InterfaceStability.Evolving
-051public class RegionServerCoprocessorHost
extends
-052
CoprocessorHostRegionServerCoprocessorHost.RegionServerEnvironment {
+033import
org.apache.yetus.audience.InterfaceAudience;
+034import
org.apache.yetus.audience.InterfaceStability;
+035import
org.apache.hadoop.hbase.coprocessor.CoprocessorHost;
+036import
org.apache.hadoop.hbase.coprocessor.MetricsCoprocessor;
+037import
org.apache.hadoop.hbase.coprocessor.ObserverContext;
+038import
org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessorEnvironment;
+039import
org.apache.hadoop.hbase.coprocessor.RegionServerObserver;
+040import
org.apache.hadoop.hbase.coprocessor.SingletonCoprocessorService;
+041import
org.apache.hadoop.hbase.ipc.RpcServer;
+042import
org.apache.hadoop.hbase.metrics.MetricRegistry;
+043import
org.apache.hadoop.hbase.replication.ReplicationEndpoint;
+044import
org.apache.hadoop.hbase.security.User;
+045import
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry;
+046
+047@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.COPROC)
+048@InterfaceStability.Evolving
+049public class RegionServerCoprocessorHost
extends
+050
CoprocessorHostRegionServerCoprocessorHost.RegionServerEnvironment {
+051
+052 private static final Log LOG =
LogFactory.getLog(RegionServerCoprocessorHost.class);
053
-054 private static final Log LOG =
LogFactory.getLog(RegionServerCoprocessorHost.class);
+054 private RegionServerServices
rsServices;
055
-056 private RegionServerServices
rsServices;
-057
-058 public
RegionServerCoprocessorHost(RegionServerServices rsServices,
-059 Configuration conf) {
-060super(rsServices);
-061this.rsServices = rsServices;
-062this.conf = conf;
-063// Log the state of coprocessor
loading here; should appear only once or
-064// twice in the daemon log, depending
on HBase version, because there is
-065// only one
RegionServerCoprocessorHost instance in the RS process
-066boolean coprocessorsEnabled =
conf.getBoolean(COPROCESSORS_ENABLED_CONF_KEY,
-067 DEFAULT_COPROCESSORS_ENABLED);
-068boolean tableCoprocessorsEnabled =
conf.getBoolean(USER_COPROCESSORS_ENABLED_CONF_KEY,
-069
DEFAULT_USER_COPROCESSORS_ENABLED);
-070LOG.info("System coprocessor loading
is " + (coprocessorsEnabled ? "enabled" : "disabled"));
-071LOG.info("Table coprocessor loading
is " +
-072 ((coprocessorsEnabled
tableCoprocessorsEnabled) ? "enabled" : "disabled"));
-073loadSystemCoprocessors(conf,
REGIONSERVER_COPROCESSOR_CONF_KEY);
-074 }
-075
-076 @Override
-077 public RegionServerEnvironment
createEnvironment(Class? implClass,
-078 Coprocessor instance, int priority,
int sequence, Configuration conf) {
-079return new
RegionServerEnvironment(implClass, instance, priority,
-080 sequence, conf, this.rsServices);
-081 }
-082
-083 public void preStop(String message,
User user) throws
[21/30] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/495ddb86/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyByteBufferCell.html
--
diff --git
a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyByteBufferCell.html
b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyByteBufferCell.html
index 18d00df..3e734a6 100644
---
a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyByteBufferCell.html
+++
b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyByteBufferCell.html
@@ -3143,7 +3143,60 @@
3135 return
Type.DeleteFamily.getCode();
3136}
3137 }
-3138}
+3138
+3139 /**
+3140 * @return An new cell is located
following input cell. If both of type and timestamp are
+3141 * minimum, the input cell
will be returned directly.
+3142 */
+3143 @InterfaceAudience.Private
+3144 public static Cell
createNextOnRowCol(Cell cell) {
+3145long ts = cell.getTimestamp();
+3146byte type = cell.getTypeByte();
+3147if (type != Type.Minimum.getCode())
{
+3148 type =
KeyValue.Type.values()[KeyValue.Type.codeToType(type).ordinal() -
1].getCode();
+3149} else if (ts !=
HConstants.OLDEST_TIMESTAMP) {
+3150 ts = ts - 1;
+3151 type = Type.Maximum.getCode();
+3152} else {
+3153 return cell;
+3154}
+3155return createNextOnRowCol(cell, ts,
type);
+3156 }
+3157
+3158 private static Cell
createNextOnRowCol(Cell cell, long ts, byte type) {
+3159if (cell instanceof ByteBufferCell)
{
+3160 return new
LastOnRowColByteBufferCell(((ByteBufferCell) cell).getRowByteBuffer(),
+3161 ((ByteBufferCell)
cell).getRowPosition(), cell.getRowLength(),
+3162 ((ByteBufferCell)
cell).getFamilyByteBuffer(),
+3163 ((ByteBufferCell)
cell).getFamilyPosition(), cell.getFamilyLength(),
+3164 ((ByteBufferCell)
cell).getQualifierByteBuffer(),
+3165 ((ByteBufferCell)
cell).getQualifierPosition(), cell.getQualifierLength()) {
+3166@Override
+3167public long getTimestamp() {
+3168 return ts;
+3169}
+3170
+3171@Override
+3172public byte getTypeByte() {
+3173 return type;
+3174}
+3175 };
+3176}
+3177return new
LastOnRowColCell(cell.getRowArray(), cell.getRowOffset(),
cell.getRowLength(),
+3178cell.getFamilyArray(),
cell.getFamilyOffset(), cell.getFamilyLength(),
+3179cell.getQualifierArray(),
cell.getQualifierOffset(), cell.getQualifierLength()) {
+3180 @Override
+3181 public long getTimestamp() {
+3182return ts;
+3183 }
+3184
+3185 @Override
+3186 public byte getTypeByte() {
+3187return type;
+3188 }
+3189};
+3190 }
+3191}
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/495ddb86/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyCell.html
--
diff --git
a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyCell.html
b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyCell.html
index 18d00df..3e734a6 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyCell.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/CellUtil.EmptyCell.html
@@ -3143,7 +3143,60 @@
3135 return
Type.DeleteFamily.getCode();
3136}
3137 }
-3138}
+3138
+3139 /**
+3140 * @return An new cell is located
following input cell. If both of type and timestamp are
+3141 * minimum, the input cell
will be returned directly.
+3142 */
+3143 @InterfaceAudience.Private
+3144 public static Cell
createNextOnRowCol(Cell cell) {
+3145long ts = cell.getTimestamp();
+3146byte type = cell.getTypeByte();
+3147if (type != Type.Minimum.getCode())
{
+3148 type =
KeyValue.Type.values()[KeyValue.Type.codeToType(type).ordinal() -
1].getCode();
+3149} else if (ts !=
HConstants.OLDEST_TIMESTAMP) {
+3150 ts = ts - 1;
+3151 type = Type.Maximum.getCode();
+3152} else {
+3153 return cell;
+3154}
+3155return createNextOnRowCol(cell, ts,
type);
+3156 }
+3157
+3158 private static Cell
createNextOnRowCol(Cell cell, long ts, byte type) {
+3159if (cell instanceof ByteBufferCell)
{
+3160 return new
LastOnRowColByteBufferCell(((ByteBufferCell) cell).getRowByteBuffer(),
+3161 ((ByteBufferCell)
cell).getRowPosition(), cell.getRowLength(),
+3162 ((ByteBufferCell)
cell).getFamilyByteBuffer(),
+3163 ((ByteBufferCell)
cell).getFamilyPosition(), cell.getFamilyLength(),
+3164 ((ByteBufferCell)
cell).getQualifierByteBuffer(),
+3165 ((ByteBufferCell)
cell).getQualifierPosition(), cell.getQualifierLength()) {
+3166@Override
+3167public long getTimestamp() {
+3168 return ts;
+3169}
+3170
+3171
[21/30] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/cef8af03/devapidocs/org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.ZKDisconnectEventWatcher.html
--
diff --git
a/devapidocs/org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.ZKDisconnectEventWatcher.html
b/devapidocs/org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.ZKDisconnectEventWatcher.html
new file mode 100644
index 000..a705818
--- /dev/null
+++
b/devapidocs/org/apache/hadoop/hbase/zookeeper/ZooKeeperWatcher.ZKDisconnectEventWatcher.html
@@ -0,0 +1,285 @@
+http://www.w3.org/TR/html4/loose.dtd;>
+
+
+
+
+
+ZooKeeperWatcher.ZKDisconnectEventWatcher (Apache HBase 3.0.0-SNAPSHOT
API)
+
+
+
+
+
+var methods = {"i0":10};
+var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],8:["t4","Concrete Methods"]};
+var altColor = "altColor";
+var rowColor = "rowColor";
+var tableTab = "tableTab";
+var activeTableTab = "activeTableTab";
+
+
+JavaScript is disabled on your browser.
+
+
+
+
+
+Skip navigation links
+
+
+
+
+Overview
+Package
+Class
+Use
+Tree
+Deprecated
+Index
+Help
+
+
+
+
+PrevClass
+NextClass
+
+
+Frames
+NoFrames
+
+
+AllClasses
+
+
+
+
+
+
+
+Summary:
+Nested|
+Field|
+Constr|
+Method
+
+
+Detail:
+Field|
+Constr|
+Method
+
+
+
+
+
+
+
+
+org.apache.hadoop.hbase.zookeeper
+Class ZooKeeperWatcher.ZKDisconnectEventWatcher
+
+
+
+http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true;
title="class or interface in java.lang">java.lang.Object
+
+
+org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher.ZKDisconnectEventWatcher
+
+
+
+
+
+
+
+All Implemented Interfaces:
+http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true;
title="class or interface in java.lang">Runnable
+
+
+Enclosing class:
+ZooKeeperWatcher
+
+
+
+class ZooKeeperWatcher.ZKDisconnectEventWatcher
+extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true;
title="class or interface in java.lang">Object
+implements http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true;
title="class or interface in java.lang">Runnable
+
+
+
+
+
+
+
+
+
+
+
+Constructor Summary
+
+Constructors
+
+Constructor and Description
+
+
+ZKDisconnectEventWatcher()
+
+
+
+
+
+
+
+
+
+Method Summary
+
+All MethodsInstance MethodsConcrete Methods
+
+Modifier and Type
+Method and Description
+
+
+void
+run()
+
+
+
+
+
+
+Methods inherited from classjava.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true;
title="class or interface in java.lang">Object
+http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#clone--;
title="class or interface in java.lang">clone, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#equals-java.lang.Object-;
title="class or interface in java.lang">equals, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#finalize--;
title="class or interface in java.lang">finalize, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#getClass--;
title="class or interface in java.lang">getClass, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#hashCode--;
title="class or interface in java.lang">hashCode, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#notify--;
title="class or interface in java.lang">notify, http://docs.oracle.com/javase/8/docs/api/java/lang
/Object.html?is-external=true#notifyAll--" title="class or interface in
java.lang">notifyAll, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#toString--;
title="class or interface in java.lang">toString, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait--;
title="class or interface in java.lang">wait, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-;
title="class or interface in java.lang">wait, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-int-;
title="class or interface in java.lang">wait
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+Constructor Detail
+
+
+
+
+
+ZKDisconnectEventWatcher
+ZKDisconnectEventWatcher()
+
+
+
+
+
+
+
+
+
+Method Detail
+
+
+
+
+
+run
+publicvoidrun()
+
+Specified by:
+http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true#run--;
title="class or interface in java.lang">runin
[21/30] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/7f23ee04/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html
--
diff --git
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html
new file mode 100644
index 000..8a3ae32
--- /dev/null
+++
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html
@@ -0,0 +1,857 @@
+http://www.w3.org/TR/html4/loose.dtd;>
+
+
+
+
+
+ReplicationSourceWALReader (Apache HBase 3.0.0-SNAPSHOT API)
+
+
+
+
+
+var methods =
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10};
+var tabs = {65535:["t0","All Methods"],2:["t2","Instance
Methods"],8:["t4","Concrete Methods"]};
+var altColor = "altColor";
+var rowColor = "rowColor";
+var tableTab = "tableTab";
+var activeTableTab = "activeTableTab";
+
+
+JavaScript is disabled on your browser.
+
+
+
+
+
+Skip navigation links
+
+
+
+
+Overview
+Package
+Class
+Use
+Tree
+Deprecated
+Index
+Help
+
+
+
+
+PrevClass
+NextClass
+
+
+Frames
+NoFrames
+
+
+AllClasses
+
+
+
+
+
+
+
+Summary:
+Nested|
+Field|
+Constr|
+Method
+
+
+Detail:
+Field|
+Constr|
+Method
+
+
+
+
+
+
+
+
+org.apache.hadoop.hbase.replication.regionserver
+Class
ReplicationSourceWALReader
+
+
+
+http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true;
title="class or interface in java.lang">java.lang.Object
+
+
+http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true;
title="class or interface in java.lang">java.lang.Thread
+
+
+org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader
+
+
+
+
+
+
+
+
+
+All Implemented Interfaces:
+http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true;
title="class or interface in java.lang">Runnable
+
+
+Direct Known Subclasses:
+RecoveredReplicationSourceWALReader
+
+
+
+@InterfaceAudience.Private
+ @InterfaceStability.Evolving
+public class ReplicationSourceWALReader
+extends http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true;
title="class or interface in java.lang">Thread
+Reads and filters WAL entries, groups the filtered entries
into batches, and puts the batches onto a queue
+
+
+
+
+
+
+
+
+
+
+
+Nested Class Summary
+
+Nested Classes
+
+Modifier and Type
+Class and Description
+
+
+(package private) static class
+ReplicationSourceWALReader.WALEntryBatch
+Holds a batch of WAL entries to replicate, along with some
statistics
+
+
+
+
+
+
+
+Nested classes/interfaces inherited from classjava.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true;
title="class or interface in java.lang">Thread
+http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.State.html?is-external=true;
title="class or interface in java.lang">Thread.State, http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.UncaughtExceptionHandler.html?is-external=true;
title="class or interface in
java.lang">Thread.UncaughtExceptionHandler
+
+
+
+
+
+
+
+
+Field Summary
+
+Fields
+
+Modifier and Type
+Field and Description
+
+
+private
org.apache.hadoop.conf.Configuration
+conf
+
+
+private long
+currentPosition
+
+
+protected http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/BlockingQueue.html?is-external=true;
title="class or interface in java.util.concurrent">BlockingQueueReplicationSourceWALReader.WALEntryBatch
+entryBatchQueue
+
+
+private boolean
+eofAutoRecovery
+
+
+private WALEntryFilter
+filter
+
+
+private org.apache.hadoop.fs.FileSystem
+fs
+
+
+private boolean
+isReaderRunning
+
+
+private static
org.apache.commons.logging.Log
+LOG
+
+
+private http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/PriorityBlockingQueue.html?is-external=true;
title="class or interface in
java.util.concurrent">PriorityBlockingQueueorg.apache.hadoop.fs.Path
+logQueue
+
+
+private int
+maxRetriesMultiplier
+
+
+protected int
+replicationBatchCountCapacity
+
+
+private long
+replicationBatchSizeCapacity
+
+
+private long
+sleepForRetries
+
+
+private ReplicationSource
+source
+
+
+private long
+totalBufferQuota
+
+
+private http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true;
title="class or interface in
[21/30] hbase-site git commit: Published site at 28cd48b673ca743d193874b2951bc995699e8e89.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/89b638a4/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html
--
diff --git
a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html
b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html
index e5d9af6..ea9ea4d 100644
---
a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html
+++
b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcServer.Listener.Reader.html
@@ -2107,556 +2107,559 @@
2099 @Override
2100 public void
onConfigurationChange(Configuration newConf) {
2101initReconfigurable(newConf);
-2102 }
-2103
-2104 private void
initReconfigurable(Configuration confToLoad) {
-2105this.allowFallbackToSimpleAuth =
confToLoad.getBoolean(FALLBACK_TO_INSECURE_CLIENT_AUTH, false);
-2106if (isSecurityEnabled
allowFallbackToSimpleAuth) {
-2107 LOG.warn("* WARNING!
*");
-2108 LOG.warn("This server is
configured to allow connections from INSECURE clients");
-2109 LOG.warn("(" +
FALLBACK_TO_INSECURE_CLIENT_AUTH + " = true).");
-2110 LOG.warn("While this option is
enabled, client identities cannot be secured, and user");
-2111 LOG.warn("impersonation is
possible!");
-2112 LOG.warn("For secure operation,
please disable SIMPLE authentication as soon as possible,");
-2113 LOG.warn("by setting " +
FALLBACK_TO_INSECURE_CLIENT_AUTH + " = false in hbase-site.xml");
-2114
LOG.warn("");
-2115}
-2116 }
-2117
-2118 /**
-2119 * Subclasses of HBaseServer can
override this to provide their own
-2120 * Connection implementations.
-2121 */
-2122 protected Connection
getConnection(SocketChannel channel, long time) {
-2123return new Connection(channel,
time);
-2124 }
-2125
-2126 /**
-2127 * Setup response for the RPC Call.
-2128 *
-2129 * @param response buffer to serialize
the response into
-2130 * @param call {@link Call} to which
we are setting up the response
-2131 * @param error error message, if the
call failed
-2132 * @throws IOException
-2133 */
-2134 private void
setupResponse(ByteArrayOutputStream response, Call call, Throwable t, String
error)
-2135 throws IOException {
-2136if (response != null)
response.reset();
-2137call.setResponse(null, null, t,
error);
-2138 }
-2139
-2140 protected void
closeConnection(Connection connection) {
-2141synchronized (connectionList) {
-2142 if
(connectionList.remove(connection)) {
-2143numConnections--;
-2144 }
-2145}
-2146connection.close();
-2147 }
-2148
-2149 Configuration getConf() {
-2150return conf;
-2151 }
-2152
-2153 /** Sets the socket buffer size used
for responding to RPCs.
-2154 * @param size send size
-2155 */
-2156 @Override
-2157 public void setSocketSendBufSize(int
size) { this.socketSendBufferSize = size; }
-2158
+2102if (scheduler instanceof
ConfigurationObserver) {
+2103
((ConfigurationObserver)scheduler).onConfigurationChange(newConf);
+2104}
+2105 }
+2106
+2107 private void
initReconfigurable(Configuration confToLoad) {
+2108this.allowFallbackToSimpleAuth =
confToLoad.getBoolean(FALLBACK_TO_INSECURE_CLIENT_AUTH, false);
+2109if (isSecurityEnabled
allowFallbackToSimpleAuth) {
+2110 LOG.warn("* WARNING!
*");
+2111 LOG.warn("This server is
configured to allow connections from INSECURE clients");
+2112 LOG.warn("(" +
FALLBACK_TO_INSECURE_CLIENT_AUTH + " = true).");
+2113 LOG.warn("While this option is
enabled, client identities cannot be secured, and user");
+2114 LOG.warn("impersonation is
possible!");
+2115 LOG.warn("For secure operation,
please disable SIMPLE authentication as soon as possible,");
+2116 LOG.warn("by setting " +
FALLBACK_TO_INSECURE_CLIENT_AUTH + " = false in hbase-site.xml");
+2117
LOG.warn("");
+2118}
+2119 }
+2120
+2121 /**
+2122 * Subclasses of HBaseServer can
override this to provide their own
+2123 * Connection implementations.
+2124 */
+2125 protected Connection
getConnection(SocketChannel channel, long time) {
+2126return new Connection(channel,
time);
+2127 }
+2128
+2129 /**
+2130 * Setup response for the RPC Call.
+2131 *
+2132 * @param response buffer to serialize
the response into
+2133 * @param call {@link Call} to which
we are setting up the response
+2134 * @param error error message, if the
call failed
+2135 * @throws IOException
+2136 */
+2137 private void
setupResponse(ByteArrayOutputStream response, Call call, Throwable t, String
error)
+2138 throws IOException {
+2139if (response != null)
response.reset();
+2140call.setResponse(null, null, t,
error);
+2141 }
+2142
+2143 protected void
closeConnection(Connection connection)
[21/30] hbase-site git commit: Published site at 845d00a16bc22cced0a2eead3d0ba48989968fb6.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6d411951/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcServer.Call.html
--
diff --git
a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcServer.Call.html
b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcServer.Call.html
index 4975851..bf27873 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcServer.Call.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcServer.Call.html
@@ -193,2475 +193,2411 @@
185 */
186 private static final int
DEFAULT_MAX_CALLQUEUE_SIZE = 1024 * 1024 * 1024;
187
-188 private static final String
WARN_DELAYED_CALLS = "hbase.ipc.warn.delayedrpc.number";
+188 private final IPCUtil ipcUtil;
189
-190 private static final int
DEFAULT_WARN_DELAYED_CALLS = 1000;
-191
-192 private final int warnDelayedCalls;
-193
-194 private AtomicInteger delayedCalls;
-195 private final IPCUtil ipcUtil;
+190 private static final String
AUTH_FAILED_FOR = "Auth failed for ";
+191 private static final String
AUTH_SUCCESSFUL_FOR = "Auth successful for ";
+192 private static final Log AUDITLOG =
LogFactory.getLog("SecurityLogger." +
+193Server.class.getName());
+194 protected
SecretManagerTokenIdentifier secretManager;
+195 protected ServiceAuthorizationManager
authManager;
196
-197 private static final String
AUTH_FAILED_FOR = "Auth failed for ";
-198 private static final String
AUTH_SUCCESSFUL_FOR = "Auth successful for ";
-199 private static final Log AUDITLOG =
LogFactory.getLog("SecurityLogger." +
-200Server.class.getName());
-201 protected
SecretManagerTokenIdentifier secretManager;
-202 protected ServiceAuthorizationManager
authManager;
-203
-204 /** This is set to Call object before
Handler invokes an RPC and ybdie
-205 * after the call returns.
-206 */
-207 protected static final
ThreadLocalCall CurCall = new ThreadLocalCall();
-208
-209 /** Keeps MonitoredRPCHandler per
handler thread. */
-210 static final
ThreadLocalMonitoredRPCHandler MONITORED_RPC
-211 = new
ThreadLocalMonitoredRPCHandler();
-212
-213 protected final InetSocketAddress
bindAddress;
-214 protected int port;
// port we listen on
-215 protected InetSocketAddress address;
// inet address we listen on
-216 private int readThreads;
// number of read threads
-217 protected int maxIdleTime;
// the maximum idle time after
-218
// which a client may be
-219
// disconnected
-220 protected int thresholdIdleConnections;
// the number of idle
-221
// connections after which we
-222
// will start cleaning up idle
-223
// connections
-224 int maxConnectionsToNuke;
// the max number of
-225
// connections to nuke
-226
// during a cleanup
-227
-228 protected MetricsHBaseServer metrics;
-229
-230 protected final Configuration conf;
-231
-232 private int maxQueueSize;
-233 protected int socketSendBufferSize;
-234 protected final boolean tcpNoDelay;
// if T then disable Nagle's Algorithm
-235 protected final boolean tcpKeepAlive;
// if T then use keepalives
-236 protected final long purgeTimeout;
// in milliseconds
+197 /** This is set to Call object before
Handler invokes an RPC and ybdie
+198 * after the call returns.
+199 */
+200 protected static final
ThreadLocalCall CurCall = new ThreadLocalCall();
+201
+202 /** Keeps MonitoredRPCHandler per
handler thread. */
+203 static final
ThreadLocalMonitoredRPCHandler MONITORED_RPC
+204 = new
ThreadLocalMonitoredRPCHandler();
+205
+206 protected final InetSocketAddress
bindAddress;
+207 protected int port;
// port we listen on
+208 protected InetSocketAddress address;
// inet address we listen on
+209 private int readThreads;
// number of read threads
+210 protected int maxIdleTime;
// the maximum idle time after
+211
// which a client may be
+212
// disconnected
+213 protected int thresholdIdleConnections;
// the number of idle
+214
// connections after which we
+215
// will start cleaning up idle
+216
// connections
+217 int maxConnectionsToNuke;
// the max number of
+218
