Uses of Interface
org.apache.cassandra.concurrent.ExecutorPlus

Packages that use ExecutorPlus

Package	Description
org.apache.cassandra.concurrent
org.apache.cassandra.db.compaction
org.apache.cassandra.metrics
org.apache.cassandra.repair
org.apache.cassandra.service

Uses of ExecutorPlus in org.apache.cassandra.concurrent

Classes in org.apache.cassandra.concurrent with type parameters of type ExecutorPlus

Modifier and Type	Interface	Description
interface	ExecutorBuilderFactory<E extends ExecutorPlus,S extends SequentialExecutorPlus>	Entry point for configuring and creating new executors.
static interface	ExecutorBuilderFactory.Jmxable<E extends ExecutorPlus,S extends SequentialExecutorPlus>	Entry point for configuring and creating new executors.
class	ThreadPoolExecutorBuilder<E extends ExecutorPlus>	Configure a ThreadPoolExecutorPlus, applying Cassandra's best practices by default Core threads may timeout, and use a default ThreadPoolExecutorBuilder.keepAlive time in ThreadPoolExecutorBuilder.keepAliveUnits Threads share the same ThreadGroup, which may be configurably a child of a specified ThreadGroup descended from the same parent of the NamedThreadFactory.MetaFactory By default queues are unbounded in length The default RejectedExecutionHandler is implementation dependent, but may be overridden The default Thread.UncaughtExceptionHandler is inherited from NamedThreadFactory.MetaFactory, which in turn receives it from the ExecutorBuilderFactory

Subinterfaces of ExecutorPlus in org.apache.cassandra.concurrent

Modifier and Type	Interface	Description
interface	LocalAwareExecutorPlus	An ExecutorPlus that is aware of, and propagates to execution, any ExecutorLocals
interface	LocalAwareSequentialExecutorPlus	A SequentialExecutorPlus that is aware of, and propagates to execution, any ExecutorLocals
interface	ScheduledExecutorPlus
interface	SequentialExecutorPlus	An ExecutorPlus that guarantees the order of execution matches the order of task submission, and provides a simple mechanism for the recurring pattern of ensuring a job is executed at least once after some point in time (i.e.

Classes in org.apache.cassandra.concurrent that implement ExecutorPlus

Modifier and Type	Class	Description
class	ImmediateExecutor
class	LocalAwareSingleThreadExecutorPlus
class	LocalAwareThreadPoolExecutorPlus
class	ScheduledThreadPoolExecutorPlus	Like ExecutorPlus, ScheduledThreadPoolExecutorPlus always logs exceptions from the tasks it is given, even if Future.get is never called elsewhere.
class	SEPExecutor
class	SingleThreadExecutorPlus
class	ThreadPoolExecutorPlus	This class inherits Executor best practices from ThreadPoolExecutorBase and ThreadPoolExecutorBuilder.
class	WrappedExecutorPlus

Fields in org.apache.cassandra.concurrent declared as ExecutorPlus

Modifier and Type	Field	Description
protected ExecutorPlus	WrappedExecutorPlus.executor

Methods in org.apache.cassandra.concurrent that return ExecutorPlus

Modifier and Type	Method	Description
ExecutorPlus	Stage.executor()
ExecutorPlus	Stage.ExecutorServiceInitialiser.init(java.lang.String jmxName, java.lang.String jmxType, int numThreads, ExecutorPlus.MaximumPoolSizeListener onSetMaximumPoolSize)

Methods in org.apache.cassandra.concurrent that return types with arguments of type ExecutorPlus

Modifier and Type	Method	Description
ExecutorBuilderFactory<ExecutorPlus,SequentialExecutorPlus>	ExecutorFactory.Default.withJmx(java.lang.String jmxPath)

Constructors in org.apache.cassandra.concurrent with parameters of type ExecutorPlus

Constructor	Description
WrappedExecutorPlus(ExecutorPlus executor)

Uses of ExecutorPlus in org.apache.cassandra.db.compaction

Classes in org.apache.cassandra.db.compaction that implement ExecutorPlus

Modifier and Type	Class	Description
static class	CompactionManager.ValidationExecutor

Uses of ExecutorPlus in org.apache.cassandra.metrics

Fields in org.apache.cassandra.metrics declared as ExecutorPlus

Modifier and Type	Field	Description
static ExecutorPlus	Sampler.samplerExecutor

Constructors in org.apache.cassandra.metrics with parameters of type ExecutorPlus

Constructor	Description
CompactionMetrics(ExecutorPlus... collectors)

Uses of ExecutorPlus in org.apache.cassandra.repair

Fields in org.apache.cassandra.repair declared as ExecutorPlus

Modifier and Type	Field	Description
ExecutorPlus	RepairSession.taskExecutor

Methods in org.apache.cassandra.repair that return ExecutorPlus

Modifier and Type	Method	Description
protected ExecutorPlus	RepairSession.createExecutor()

Methods in org.apache.cassandra.repair with parameters of type ExecutorPlus

Modifier and Type	Method	Description
default Future<CoordinatedRepairResult>	RepairTask.perform(ExecutorPlus executor, Scheduler validationScheduler)
Future<CoordinatedRepairResult>	IncrementalRepairTask.performUnsafe(ExecutorPlus executor, Scheduler validationScheduler)
Future<CoordinatedRepairResult>	NormalRepairTask.performUnsafe(ExecutorPlus executor, Scheduler validationScheduler)
Future<CoordinatedRepairResult>	PreviewRepairTask.performUnsafe(ExecutorPlus executor, Scheduler validationScheduler)
Future<CoordinatedRepairResult>	RepairTask.performUnsafe(ExecutorPlus executor, Scheduler validationScheduler)
protected Future<CoordinatedRepairResult>	AbstractRepairTask.runRepair(TimeUUID parentSession, boolean isIncremental, ExecutorPlus executor, Scheduler validationScheduler, java.util.List<CommonRange> commonRanges, java.lang.String... cfnames)
void	RepairSession.start(ExecutorPlus executor)	Start RepairJob on given ColumnFamilies.

Uses of ExecutorPlus in org.apache.cassandra.service

Fields in org.apache.cassandra.service declared as ExecutorPlus

Modifier and Type	Field	Description
ExecutorPlus	ActiveRepairService.snapshotExecutor

Methods in org.apache.cassandra.service that return ExecutorPlus

Modifier and Type	Method	Description
static ExecutorPlus	ActiveRepairService.repairCommandExecutor()

Methods in org.apache.cassandra.service with parameters of type ExecutorPlus

Modifier and Type	Method	Description
RepairSession	ActiveRepairService.submitRepairSession(TimeUUID parentRepairSession, CommonRange range, java.lang.String keyspace, RepairParallelism parallelismDegree, boolean isIncremental, boolean pullRepair, PreviewKind previewKind, boolean optimiseStreams, boolean repairPaxos, boolean paxosOnly, ExecutorPlus executor, Scheduler validationScheduler, java.lang.String... cfnames)	Requests repairs for the given keyspace and column families.