com.exalead.mercury.mami.indexing.v10

Class FixedThreadsAnalysisPolicy

java.lang.Object

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

com.exalead.mercury.mami.indexing.v10.FixedThreadsAnalysisPolicy

All Implemented Interfaces:

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

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

Instantiates a fixed number of analysis threads.
Dispatches documents according to their DIDs (Document IDs) and slice.

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
FixedThreadsAnalysisPolicy()
FixedThreadsAnalysisPolicy(FixedThreadsAnalysisPolicy 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 FixedThreadsAnalysisPolicy.
static FixedThreadsAnalysisPolicy	fromString(java.lang.String s) String representation of this FixedThreadsAnalysisPolicy.
int	getNbThreads() Number of threads to allocate.
FixedThreadsAnalysisPolicy	makeCopy() Creates and returns a deep copy of this FixedThreadsAnalysisPolicy.
static FixedThreadsAnalysisPolicy	readFrom(java.io.InputStream is) Read this FixedThreadsAnalysisPolicy from an XML fragment.
void	setNbThreads(int nbThreads) Number of threads to allocate.
java.lang.String	toString() String representation of this FixedThreadsAnalysisPolicy.
FixedThreadsAnalysisPolicy	withMaxRAMConsumptionMB(int maxRAMConsumptionMB)
FixedThreadsAnalysisPolicy	withMaxRAMConsumptionMB(java.lang.Integer maxRAMConsumptionMB)
FixedThreadsAnalysisPolicy	withMaxRAMConsumptionThreshold(java.lang.String maxRAMConsumptionThreshold)
FixedThreadsAnalysisPolicy	withNbThreads(int nbThreads)
FixedThreadsAnalysisPolicy	withNbThreads(java.lang.Integer nbThreads)
void	writeTo(java.io.OutputStream os) Write this FixedThreadsAnalysisPolicy 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

FixedThreadsAnalysisPolicy

public FixedThreadsAnalysisPolicy()

FixedThreadsAnalysisPolicy

public FixedThreadsAnalysisPolicy(FixedThreadsAnalysisPolicy o)

Copy constructor

Method Detail

withMaxRAMConsumptionThreshold

public FixedThreadsAnalysisPolicy withMaxRAMConsumptionThreshold(java.lang.String maxRAMConsumptionThreshold)

Overrides:

withMaxRAMConsumptionThreshold in class AnalysisPolicy

withMaxRAMConsumptionMB

public FixedThreadsAnalysisPolicy withMaxRAMConsumptionMB(int maxRAMConsumptionMB)

Overrides:

withMaxRAMConsumptionMB in class AnalysisPolicy

withMaxRAMConsumptionMB

public FixedThreadsAnalysisPolicy withMaxRAMConsumptionMB(java.lang.Integer maxRAMConsumptionMB)

Overrides:

withMaxRAMConsumptionMB in class AnalysisPolicy

setNbThreads

public void setNbThreads(int nbThreads)

Number of threads to allocate.

getNbThreads

public int getNbThreads()

Number of threads to allocate.

withNbThreads

public FixedThreadsAnalysisPolicy withNbThreads(int nbThreads)

withNbThreads

public FixedThreadsAnalysisPolicy withNbThreads(java.lang.Integer nbThreads)

makeCopy

public FixedThreadsAnalysisPolicy makeCopy()

Creates and returns a deep copy of this FixedThreadsAnalysisPolicy.

Overrides:

makeCopy in class AnalysisPolicy

readFrom

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

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

Overrides:

writeTo in class AnalysisPolicy

Throws:

javax.xml.bind.JAXBException

java.io.IOException

fromString

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

String representation of this FixedThreadsAnalysisPolicy.

Throws:

javax.xml.bind.JAXBException

java.io.UnsupportedEncodingException

toString

public java.lang.String toString()

String representation of this FixedThreadsAnalysisPolicy.

Overrides:

toString in class AnalysisPolicy

check

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

Checks this FixedThreadsAnalysisPolicy.

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