com.exalead.mercury.mami.indexing.v10

Class InactivityCommitTriggerCondition

java.lang.Object

com.exalead.mercury.mami.indexing.v10.CommitTriggerCondition

com.exalead.mercury.mami.indexing.v10.InactivityCommitTriggerCondition

All Implemented Interfaces:

com.exalead.util.Checkable, java.io.Serializable

public class InactivityCommitTriggerCondition
extends CommitTriggerCondition
implements com.exalead.util.Checkable, java.io.Serializable

Inactivity-based condition. This condition is triggered when:

• there is no new data for the specified time period
• AND at least the specified No. tasks has been analyzed.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class com.exalead.mercury.mami.indexing.v10.CommitTriggerCondition

CommitTriggerCondition.Transformer<T>, CommitTriggerCondition.Visitor

Field Summary

Fields

Modifier and Type	Field and Description
long	inactivityTimeMs
long	inactivityTimeS
int	numberOfTasks

Constructor Summary

Constructors

Constructor and Description
InactivityCommitTriggerCondition()
InactivityCommitTriggerCondition(InactivityCommitTriggerCondition o) Copy constructor

Method Summary

Modifier and Type	Method and Description
<T> T	accept(CommitTriggerCondition.Transformer<T> transformer, T[] t)
void	accept(CommitTriggerCondition.Visitor visitor)
void	check(boolean deep, java.lang.String errorContext) Checks this InactivityCommitTriggerCondition.
static InactivityCommitTriggerCondition	fromString(java.lang.String s) String representation of this InactivityCommitTriggerCondition.
long	getInactivityTimeMs() After N milliseconds of no indexing activity, it is defined as inactive. If both timeS and timeMs are set, wait 1000*timeS + timeMs milliseconds.
long	getInactivityTimeS() After N seconds of no indexing activity, it is defined as inactive.
int	getNumberOfTasks() Minimum number of tasks to trigger a commit.
InactivityCommitTriggerCondition	makeCopy() Creates and returns a deep copy of this InactivityCommitTriggerCondition.
static InactivityCommitTriggerCondition	readFrom(java.io.InputStream is) Read this InactivityCommitTriggerCondition from an XML fragment.
void	setInactivityTimeMs(long inactivityTimeMs) After N milliseconds of no indexing activity, it is defined as inactive. If both timeS and timeMs are set, wait 1000*timeS + timeMs milliseconds.
void	setInactivityTimeS(long inactivityTimeS) After N seconds of no indexing activity, it is defined as inactive.
void	setNumberOfTasks(int numberOfTasks) Minimum number of tasks to trigger a commit.
java.lang.String	toString() String representation of this InactivityCommitTriggerCondition.
InactivityCommitTriggerCondition	withInactivityTimeMs(long inactivityTimeMs)
InactivityCommitTriggerCondition	withInactivityTimeMs(java.lang.Long inactivityTimeMs)
InactivityCommitTriggerCondition	withInactivityTimeS(long inactivityTimeS)
InactivityCommitTriggerCondition	withInactivityTimeS(java.lang.Long inactivityTimeS)
InactivityCommitTriggerCondition	withNumberOfTasks(int numberOfTasks)
InactivityCommitTriggerCondition	withNumberOfTasks(java.lang.Integer numberOfTasks)
void	writeTo(java.io.OutputStream os) Write this InactivityCommitTriggerCondition as an XML fragment

Methods inherited from class java.lang.Object

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

Field Detail

numberOfTasks

public int numberOfTasks

inactivityTimeS

public long inactivityTimeS

inactivityTimeMs

public long inactivityTimeMs

Constructor Detail

InactivityCommitTriggerCondition

public InactivityCommitTriggerCondition()

InactivityCommitTriggerCondition

public InactivityCommitTriggerCondition(InactivityCommitTriggerCondition o)

Copy constructor

Method Detail

setNumberOfTasks

public void setNumberOfTasks(int numberOfTasks)

Minimum number of tasks to trigger a commit.

getNumberOfTasks

public int getNumberOfTasks()

Minimum number of tasks to trigger a commit.

withNumberOfTasks

public InactivityCommitTriggerCondition withNumberOfTasks(int numberOfTasks)

withNumberOfTasks

public InactivityCommitTriggerCondition withNumberOfTasks(java.lang.Integer numberOfTasks)

setInactivityTimeS

public void setInactivityTimeS(long inactivityTimeS)

After N seconds of no indexing activity, it is defined as inactive.

getInactivityTimeS

public long getInactivityTimeS()

After N seconds of no indexing activity, it is defined as inactive.

withInactivityTimeS

public InactivityCommitTriggerCondition withInactivityTimeS(long inactivityTimeS)

withInactivityTimeS

public InactivityCommitTriggerCondition withInactivityTimeS(java.lang.Long inactivityTimeS)

setInactivityTimeMs

public void setInactivityTimeMs(long inactivityTimeMs)

After N milliseconds of no indexing activity, it is defined as inactive.
If both timeS and timeMs are set, wait 1000*timeS + timeMs milliseconds.

getInactivityTimeMs

public long getInactivityTimeMs()

After N milliseconds of no indexing activity, it is defined as inactive.
If both timeS and timeMs are set, wait 1000*timeS + timeMs milliseconds.

withInactivityTimeMs

public InactivityCommitTriggerCondition withInactivityTimeMs(long inactivityTimeMs)

withInactivityTimeMs

public InactivityCommitTriggerCondition withInactivityTimeMs(java.lang.Long inactivityTimeMs)

makeCopy

public InactivityCommitTriggerCondition makeCopy()

Creates and returns a deep copy of this InactivityCommitTriggerCondition.

Overrides:

makeCopy in class CommitTriggerCondition

readFrom

public static InactivityCommitTriggerCondition readFrom(java.io.InputStream is)
                                                 throws javax.xml.bind.JAXBException

Read this InactivityCommitTriggerCondition from an XML fragment.

Throws:

javax.xml.bind.JAXBException

writeTo

public void writeTo(java.io.OutputStream os)
             throws javax.xml.bind.JAXBException,
                    java.io.IOException

Write this InactivityCommitTriggerCondition as an XML fragment

Overrides:

writeTo in class CommitTriggerCondition

Throws:

javax.xml.bind.JAXBException

java.io.IOException

fromString

public static InactivityCommitTriggerCondition fromString(java.lang.String s)
                                                   throws javax.xml.bind.JAXBException,
                                                          java.io.UnsupportedEncodingException

String representation of this InactivityCommitTriggerCondition.

Throws:

javax.xml.bind.JAXBException

java.io.UnsupportedEncodingException

toString

public java.lang.String toString()

String representation of this InactivityCommitTriggerCondition.

Overrides:

toString in class CommitTriggerCondition

check

public void check(boolean deep,
                  java.lang.String errorContext)
           throws com.exalead.util.TypedException

Checks this InactivityCommitTriggerCondition.

Specified by:

check in interface com.exalead.util.Checkable

Overrides:

check in class CommitTriggerCondition

Throws:

com.exalead.util.TypedException

accept

public void accept(CommitTriggerCondition.Visitor visitor)
            throws com.exalead.util.TypedException

Specified by:

accept in class CommitTriggerCondition

Throws:

com.exalead.util.TypedException

accept

public <T> T accept(CommitTriggerCondition.Transformer<T> transformer,
                    T[] t)
             throws com.exalead.util.TypedException

Specified by:

accept in class CommitTriggerCondition

Throws:

com.exalead.util.TypedException