org.apache.solr.cloud.autoscaling

Class NodeAddedTrigger

java.lang.Object

org.apache.solr.cloud.autoscaling.TriggerBase

org.apache.solr.cloud.autoscaling.NodeAddedTrigger

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable, AutoScaling.Trigger

public class NodeAddedTrigger
extends TriggerBase

Trigger for the TriggerEventType.NODEADDED event

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NodeAddedTrigger.NodeAddedEvent

Field Summary

Fields inherited from class org.apache.solr.cloud.autoscaling.TriggerBase

lastState, zkClient

Constructor Summary

Constructors

Constructor and Description
NodeAddedTrigger(String name, Map<String,Object> properties, CoreContainer container, ZkController zkController)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	equals(Object obj)
List<TriggerAction>	getActions() Actions to execute when event is fired.
TriggerEventType	getEventType() Event type generated by this trigger.
String	getName() Trigger name.
AutoScaling.TriggerEventProcessor	getProcessor() Get event processor.
Map<String,Object>	getProperties() Trigger properties.
protected Map<String,Object>	getState() Prepare and return internal state of this trigger in a format suitable for persisting in ZK.
int	getWaitForSecond() Number of seconds to wait between fired events ("waitFor" property).
int	hashCode()
void	init() Called before a trigger is scheduled.
boolean	isClosed() Return true when this trigger is closed and cannot be used.
boolean	isEnabled() Returns true if this trigger is enabled.
void	restoreState(AutoScaling.Trigger old) Set internal state of this trigger from another instance.
void	run()
void	setProcessor(AutoScaling.TriggerEventProcessor processor) Set event processor to call when event is fired.
protected void	setState(Map<String,Object> state) Restore internal state of this trigger from properties retrieved from ZK.

Methods inherited from class org.apache.solr.cloud.autoscaling.TriggerBase

restoreState, saveState

Methods inherited from class java.lang.Object

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

Constructor Detail

NodeAddedTrigger

public NodeAddedTrigger(String name,
                        Map<String,Object> properties,
                        CoreContainer container,
                        ZkController zkController)

Method Detail

init

public void init()

Description copied from interface: AutoScaling.Trigger

Called before a trigger is scheduled. Any heavy object creation or initialisation should be done in this method instead of the Trigger's constructor.

setProcessor

public void setProcessor(AutoScaling.TriggerEventProcessor processor)

Description copied from interface: AutoScaling.Trigger

Set event processor to call when event is fired.

getProcessor

public AutoScaling.TriggerEventProcessor getProcessor()

Description copied from interface: AutoScaling.Trigger

Get event processor.

getName

public String getName()

Description copied from interface: AutoScaling.Trigger

Trigger name.

getEventType

public TriggerEventType getEventType()

Description copied from interface: AutoScaling.Trigger

Event type generated by this trigger.

isEnabled

public boolean isEnabled()

Description copied from interface: AutoScaling.Trigger

Returns true if this trigger is enabled.

getWaitForSecond

public int getWaitForSecond()

Description copied from interface: AutoScaling.Trigger

Number of seconds to wait between fired events ("waitFor" property).

getProperties

public Map<String,Object> getProperties()

Description copied from interface: AutoScaling.Trigger

Trigger properties.

getActions

public List<TriggerAction> getActions()

Description copied from interface: AutoScaling.Trigger

Actions to execute when event is fired.

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

close

public void close()
           throws IOException

Throws:

IOException

restoreState

public void restoreState(AutoScaling.Trigger old)

Description copied from interface: AutoScaling.Trigger

Set internal state of this trigger from another instance.

getState

protected Map<String,Object> getState()

Description copied from class: TriggerBase

Prepare and return internal state of this trigger in a format suitable for persisting in ZK.

Specified by:

getState in class TriggerBase

Returns:

map of internal state properties. Note: values must be supported by Utils.toJSON(Object).

setState

protected void setState(Map<String,Object> state)

Description copied from class: TriggerBase

Restore internal state of this trigger from properties retrieved from ZK.

Specified by:

setState in class TriggerBase

Parameters:

state - never null but may be empty.

run

public void run()

isClosed

public boolean isClosed()

Description copied from interface: AutoScaling.Trigger

Return true when this trigger is closed and cannot be used.