Dear Wiki user, You have subscribed to a wiki page or wiki category on "Cassandra Wiki" for change notification.
The "JmxInterface" page has been changed by RobertColi. http://wiki.apache.org/cassandra/JmxInterface?action=diff&rev1=10&rev2=11 -------------------------------------------------- - <<Anchor(org.apache.cassandra.concurrent.AE-SERVICE-STAGE)>> + <<Anchor(org.apache.cassandra.concurrent)>> = org.apache.cassandra.concurrent = All org.apache.cassandra.concurrent Types are thread pool executors which have Attributes [[#org.apache.cassandra.concurrent.<THREADPOOL>.Attributes.ActiveCount|ActiveCount]], [[#org.apache.cassandra.concurrent.<THREADPOOL>.Attributes.CompletedTasks|CompletedTasks]] and [[#org.apache.cassandra.concurrent.<THREADPOOL>.Attributes.PendingTasks|PendingTasks]]. They are viewable from the command line with '''{{{'}}}nodeprobe tpstats{{{'}}}'''. @@ -51, +51 @@ ||Units ||Notes || ||integer >=0, tasks ||The number of tasks waiting in the queue to be executed. || - <<Anchor(org.apache.cassandra.concurrent.AE-SERVICE-STAGE)>> == org.apache.cassandra.concurrent.AE-SERVICE-STAGE == + This thread pool is single threaded. + Per src/java/org/apache/cassandra/service/AntiEntropyService.java, {{{ AntiEntropyService encapsulates "validating" (hashing) individual column families, exchanging MerkleTrees with remote nodes via a TreeRequest/Response conversation, and then triggering repairs for disagreeing ranges. @@ -71, +72 @@ <<Anchor(org.apache.cassandra.concurrent.FILEUTILS-DELETE-POOL)>> == org.apache.cassandra.concurrent.FILEUTILS-DELETE-POOL == - Code is defined in src/java/org/apache/cassandra/io/DeletionService.java, but use cases are not commented there. This executor is responsible for deleting files, such as obsolete sstables and obsolete commitlog segments. + This thread pool is single threaded. Code is defined in src/java/org/apache/cassandra/io/DeletionService.java. This executor is responsible for deleting files, such as obsolete sstables and obsolete commitlog segments. <<Anchor(org.apache.cassandra.concurrent.FLUSH-SORTER-POOL)>> == org.apache.cassandra.concurrent.FLUSH-SORTER-POOL == @@ -113, +114 @@ <<Anchor(org.apache.cassandra.concurrent.GMFD)>> == org.apache.cassandra.concurrent.GMFD == - The thread pool executor for the [[ArchitectureGossip|Gossiper]]. + This thread pool is single threaded. Executor for the [[ArchitectureGossip|Gossiper]]. <<Anchor(org.apache.cassandra.concurrent.HINTED-HANDOFF-POOL)>> == org.apache.cassandra.concurrent.HINTED-HANDOFF-POOL == + This thread pool is single threaded. + Per src/java/org/apache/cassandra/db/HintedHandOffManager.java, {{{ * For each table (keyspace), there is a row in the system hints CF. @@ -130, +133 @@ <<Anchor(org.apache.cassandra.concurrent.LB-OPERATIONS)>> == org.apache.cassandra.concurrent.LB-OPERATIONS == + This thread pool is single threaded. + See Also : [[#org.apache.cassandra.concurrent.LB-TARGET|LB-TARGET]]. Per src/java/org/apache/cassandra/service/StorageLoadBalancer.java, {{{ /* This thread pool is used for initiating load balancing operations */ @@ -137, +142 @@ <<Anchor(org.apache.cassandra.concurrent.LB-TARGET)>> == org.apache.cassandra.concurrent.LB-TARGET == + This thread pool is single threaded. + See Also : [[#org.apache.cassandra.concurrent.LB-OPERATIONS|LB-OPERATIONS]]. Per src/java/org/apache/cassandra/service/StorageLoadBalancer.java, {{{ /* This thread pool is used by target node to leave the ring. */ @@ -144, +151 @@ <<Anchor(org.apache.cassandra.concurrent.LOAD-BALANCER-STAGE)>> == org.apache.cassandra.concurrent.LOAD-BALANCER-STAGE == + This thread pool is single threaded. - Per src/java/org/apache/cassandra/service/ - {{{ - }}} <<Anchor(org.apache.cassandra.concurrent.MEMTABLE-POST-FLUSHER)>> == org.apache.cassandra.concurrent.MEMTABLE-POST-FLUSHER == + This thread pool is single threaded. + See Also : [[#org.apache.cassandra.concurrent.FLUSH-SORTER-POOL|FLUSH-SORTER-POOL]] and [[#org.apache.cassandra.concurrent.FLUSH-WRITER-POOL|FLUSH-WRITER-POOL]]. Per src/java/org/apache/cassandra/db/ColumnFamilyStore.java, {{{ * submitFlush first puts [Binary]Memtable.getSortedContents on the flushSorter executor, @@ -175, +182 @@ <<Anchor(org.apache.cassandra.concurrent.MESSAGE-STREAMING-POOL)>> == org.apache.cassandra.concurrent.MESSAGE-STREAMING-POOL == + This thread pool is single threaded. + FIXME: How does this relate to MESSAGE-DESERIALIZER-POOL? <<Anchor(org.apache.cassandra.concurrent.RESPONSE-STAGE)>> == org.apache.cassandra.concurrent.RESPONSE-STAGE == + This stage is multi-threaded. - Per src/java/org/apache/cassandra/service/ - {{{ - }}} <<Anchor(org.apache.cassandra.concurrent.ROW-MUTATION-STAGE)>> == org.apache.cassandra.concurrent.ROW-MUTATION-STAGE == + This stage is multi-threaded. - Per src/java/org/apache/cassandra/service/ - {{{ - }}} <<Anchor(org.apache.cassandra.concurrent.ROW-READ-STAGE)>> == org.apache.cassandra.concurrent.ROW-READ-STAGE == + This stage is multi-threaded. - Per src/java/org/apache/cassandra/service/ - {{{ - }}} <<Anchor(org.apache.cassandra.concurrent.STREAM-STAGE)>> == org.apache.cassandra.concurrent.STREAM-STAGE == + This stage is single threaded. - Per src/java/org/apache/cassandra/service/ - {{{ - }}} <<Anchor(org.apache.cassandra.db.CommitLog)>> <<Anchor(org.apache.cassandra.db.CommitLog.Attributes.ActiveCount)>> <<Anchor(org.apache.cassandra.db.CommitLog.Attributes.CompletedTasks)>> <<Anchor(org.apache.cassandra.db.CommitLog.Attributes.PendingTasks)>> <<Anchor(org.apache.cassandra.db.CompactionManager.Attributes.BytesCompacted)>> <<Anchor(org.apache.cassandra.db.CompactionManager.Attributes.BytesTotalInProgress)>> <<Anchor(org.apache.cassandra.db.CompactionManager.Attributes.ColumnFamilyInProgress)>> <<Anchor(org.apache.cassandra.db.CompactionManager.Attributes.MaximumCompactionThreshold)>> <<Anchor(org.apache.cassandra.db.CompactionManager.Attributes.MinmumCompactionThreshold)>> <<Anchor(org.apache.cassandra.db.CompactionManager.Attributes.PendingTasks)>> <<Anchor(org.apache.cassandra.db.CompactionManager)>> <<Anchor(org.apache.cassandra.gms)>> <<Anchor(org.apache.cassandra.gms.FailureDetector.Operations.dumpInterArrivalTimes)>> <<Anchor(org.apache.cassandra.service.StorageProxy)>> <<Anchor(org.apache.cassandra.service.StorageProxy.Attributes.RangeLatency)>> <<Anchor(org.apache.cassandra.service.StorageProxy.Attributes.RangeOperations)>> <<Anchor(org.apache.cassandra.service.StorageProxy.Attributes.ReadLatency)>> <<Anchor(org.apache.cassandra.service.StorageProxy.Attributes.WriteLatency)>> <<Anchor(org.apache.cassandra.service.StorageProxy.Attributes.WriteOperations)>> <<Anchor(org.apache.cassandra.service.StorageService)>> <<Anchor(org.apache.cassandra.service.StorageService.Attributes.CurrentGenerationNumber)>> <<Anchor(org.apache.cassandra.service.StorageService.Attributes.LiveNodes)>> <<Anchor(org.apache.cassandra.service.StorageService.Attributes.LoadMap)>> <<Anchor(org.apache.cassandra.service.StorageService.Attributes.LoadString)>> <<Anchor(org.apache.cassandra.service.StorageService.Attributes.RangeToEndPointMap)>> <<Anchor(org.apache.cassandra.service.StorageService.Attributes.Token)>> <<Anchor(org.apache.cassandra.service.StorageService.Attributes.UnreachableNodes)>> <<Anchor(org.apache.cassandra.service.StorageService.Operations.clearSnapshot)>> <<Anchor(org.apache.cassandra.service.StorageService.Operations.decommission)>> <<Anchor(org.apache.cassandra.service.StorageService.Operations.forceTableCleanup)>> <<Anchor(org.apache.cassandra.service.StorageService.Operations.forceTableCompaction)>> <<Anchor(org.apache.cassandra.service.StorageService.Operations.forceTableFlush)>> <<Anchor(org.apache.cassandra.service.StorageService.Operations.forceTableRepair)>> <<Anchor(org.apache.cassandra.service.StorageService.Operations.getLiveNaturalEndpoints)>> <<Anchor(org.apache.cassandra.service.StorageService.Operations.loadBalance)>> <<Anchor(org.apache.cassandra.service.StorageService.Operations.move)>> <<Anchor(org.apache.cassandra.service.StorageService.Operations.removeToken)>> <<Anchor(org.apache.cassandra.service.StorageService.Operations.setLog4jLevel)>> <<Anchor(org.apache.cassandra.service.StorageService.Operations.takeAllSnapshot)>> <<Anchor(org.apache.cassandra.service.StorageService.Operations.takeSnapshot)>>
