Package org.apache.accumulo.core.spi.compaction

Class SimpleCompactionDispatcher

java.lang.Object

org.apache.accumulo.core.spi.compaction.SimpleCompactionDispatcher

All Implemented Interfaces:

CompactionDispatcher

public class SimpleCompactionDispatcher
extends Object
implements CompactionDispatcher

Dispatcher that supports simple configuration for making tables use compaction services. By default, it dispatches to the compaction service named default "default".

The following schema is supported for configuration options.

table.compaction.dispatcher.opts.service[.user[.<user type>]|selector|system|chop]= <service>

The following configuration will make a table use compaction service cs9 for user compactions, service cs4 for chop compactions, and service cs7 for everything else.

table.compaction.dispatcher.opts.service=cs7 table.compaction.dispatcher.opts.service.user=cs9 table.compaction.dispatcher.opts.service.chop=cs4

Compactions started using the client API are called user compactions and can set execution hints using CompactionConfig.setExecutionHints(Map). Hints of the form compaction_type=<user type> can be used by this dispatcher. For example the following will use service cs2 when the hint compaction_type=urgent is seen, service cs3 when hint compaction_type=trifling, everything else uses cs9.

table.compaction.dispatcher.opts.service=cs9 table.compaction.dispatcher.opts.service.user.urgent=cs2 table.compaction.dispatcher.opts.service.user.trifling=cs3

See Also:

• org.apache.accumulo.core.spi.compaction

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.accumulo.core.spi.compaction.CompactionDispatcher

CompactionDispatcher.DispatchParameters, CompactionDispatcher.InitParameters

Constructor Summary

Constructors

Constructor	Description
SimpleCompactionDispatcher()

Method Summary

Modifier and Type	Method	Description
CompactionDispatch	dispatch(CompactionDispatcher.DispatchParameters params)	Accumulo calls this method for compactions to determine what service to use.
void	init(CompactionDispatcher.InitParameters params)	This method is called once after a CompactionDispatcher is instantiated.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SimpleCompactionDispatcher

public SimpleCompactionDispatcher()

Method Details

init

public void init(CompactionDispatcher.InitParameters params)

Description copied from interface: CompactionDispatcher

This method is called once after a CompactionDispatcher is instantiated.

Specified by:

init in interface CompactionDispatcher

dispatch

public CompactionDispatch dispatch(CompactionDispatcher.DispatchParameters params)

Description copied from interface: CompactionDispatcher

Accumulo calls this method for compactions to determine what service to use.

Specified by:

dispatch in interface CompactionDispatcher