com.exalead.mercury.mami.indexing.v10

Class PerSliceAnalysisPolicy

java.lang.Object

com.exalead.mercury.mami.indexing.v10.AnalysisPolicy

com.exalead.mercury.mami.indexing.v10.PerSliceAnalysisPolicy

All Implemented Interfaces:

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

public class PerSliceAnalysisPolicy
extends AnalysisPolicy
implements com.exalead.util.Checkable, java.io.Serializable

Instantiates an analysis thread for each slice.
Dispatches documents according to their slice.
Consumes less RAM than the 'FixedThreadsAnalysisPolicy'.

See Also:

Serialized Form

Nested Class Summary

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

AnalysisPolicy.MaxRAMConsumptionThreshold, AnalysisPolicy.Transformer<T>, AnalysisPolicy.Visitor

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_NB_THREADS
int	nbThreads

Fields inherited from class com.exalead.mercury.mami.indexing.v10.AnalysisPolicy

DEFAULT_MAX_R_A_M_CONSUMPTION_M_B, DEFAULT_MAX_R_A_M_CONSUMPTION_THRESHOLD, maxRAMConsumptionMB, maxRAMConsumptionThreshold

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
<T> T	accept(AnalysisPolicy.Transformer<T> transformer, T[] t)
void	accept(AnalysisPolicy.Visitor visitor)
void	check(boolean deep, java.lang.String errorContext) Checks this PerSliceAnalysisPolicy.
static PerSliceAnalysisPolicy	fromString(java.lang.String s) String representation of this PerSliceAnalysisPolicy.
int	getNbThreads() Uses N threads per slice.
PerSliceAnalysisPolicy	makeCopy() Creates and returns a deep copy of this PerSliceAnalysisPolicy.
static PerSliceAnalysisPolicy	readFrom(java.io.InputStream is) Read this PerSliceAnalysisPolicy from an XML fragment.
void	setNbThreads(int nbThreads) Uses N threads per slice.
java.lang.String	toString() String representation of this PerSliceAnalysisPolicy.
PerSliceAnalysisPolicy	withMaxRAMConsumptionMB(int maxRAMConsumptionMB)
PerSliceAnalysisPolicy	withMaxRAMConsumptionMB(java.lang.Integer maxRAMConsumptionMB)
PerSliceAnalysisPolicy	withMaxRAMConsumptionThreshold(java.lang.String maxRAMConsumptionThreshold)
PerSliceAnalysisPolicy	withNbThreads(int nbThreads)
PerSliceAnalysisPolicy	withNbThreads(java.lang.Integer nbThreads)
void	writeTo(java.io.OutputStream os) Write this PerSliceAnalysisPolicy as an XML fragment

Methods inherited from class com.exalead.mercury.mami.indexing.v10.AnalysisPolicy

getMaxRAMConsumptionMB, getMaxRAMConsumptionThreshold, getMaxRAMConsumptionThresholdAsEnum, isA, isOneOf, setMaxRAMConsumptionMB, setMaxRAMConsumptionThreshold, setMaxRAMConsumptionThreshold

Methods inherited from class java.lang.Object

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

Field Detail

nbThreads

public int nbThreads

DEFAULT_NB_THREADS

public static final int DEFAULT_NB_THREADS

See Also:

Constant Field Values

Constructor Detail

PerSliceAnalysisPolicy

public PerSliceAnalysisPolicy()

PerSliceAnalysisPolicy

public PerSliceAnalysisPolicy(PerSliceAnalysisPolicy o)

Copy constructor

Method Detail

withMaxRAMConsumptionThreshold

public PerSliceAnalysisPolicy withMaxRAMConsumptionThreshold(java.lang.String maxRAMConsumptionThreshold)

Overrides:

withMaxRAMConsumptionThreshold in class AnalysisPolicy

withMaxRAMConsumptionMB

public PerSliceAnalysisPolicy withMaxRAMConsumptionMB(int maxRAMConsumptionMB)

Overrides:

withMaxRAMConsumptionMB in class AnalysisPolicy

withMaxRAMConsumptionMB

public PerSliceAnalysisPolicy withMaxRAMConsumptionMB(java.lang.Integer maxRAMConsumptionMB)

Overrides:

withMaxRAMConsumptionMB in class AnalysisPolicy

setNbThreads

public void setNbThreads(int nbThreads)

Uses N threads per slice.

getNbThreads

public int getNbThreads()

Uses N threads per slice.

withNbThreads

public PerSliceAnalysisPolicy withNbThreads(int nbThreads)

withNbThreads

public PerSliceAnalysisPolicy withNbThreads(java.lang.Integer nbThreads)

makeCopy

public PerSliceAnalysisPolicy makeCopy()

Creates and returns a deep copy of this PerSliceAnalysisPolicy.

Overrides:

makeCopy in class AnalysisPolicy

readFrom

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

Read this PerSliceAnalysisPolicy 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 PerSliceAnalysisPolicy as an XML fragment

Overrides:

writeTo in class AnalysisPolicy

Throws:

javax.xml.bind.JAXBException

java.io.IOException

fromString

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

String representation of this PerSliceAnalysisPolicy.

Throws:

javax.xml.bind.JAXBException

java.io.UnsupportedEncodingException

toString

public java.lang.String toString()

String representation of this PerSliceAnalysisPolicy.

Overrides:

toString in class AnalysisPolicy

check

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

Checks this PerSliceAnalysisPolicy.

Specified by:

check in interface com.exalead.util.Checkable

Overrides:

check in class AnalysisPolicy

Throws:

com.exalead.util.TypedException

accept

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

Specified by:

accept in class AnalysisPolicy

Throws:

com.exalead.util.TypedException

accept

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

Specified by:

accept in class AnalysisPolicy

Throws:

com.exalead.util.TypedException