com.exalead.mercury.mami.indexing.v10

Class ParallelImportPolicy

java.lang.Object

com.exalead.mercury.mami.indexing.v10.ImportPolicy

com.exalead.mercury.mami.indexing.v10.ParallelImportPolicy

All Implemented Interfaces:

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

public class ParallelImportPolicy
extends ImportPolicy
implements com.exalead.util.Checkable, java.io.Serializable

For each analysis buffers one generation is created.
Analysis buffers are imported in parallel.

See Also:

Serialized Form

Nested Class Summary

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

ImportPolicy.Transformer<T>, ImportPolicy.Visitor

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_NB_THREADS
int	nbThreads

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
<T> T	accept(ImportPolicy.Transformer<T> transformer, T[] t)
void	accept(ImportPolicy.Visitor visitor)
void	check(boolean deep, java.lang.String errorContext) Checks this ParallelImportPolicy.
static ParallelImportPolicy	fromString(java.lang.String s) String representation of this ParallelImportPolicy.
int	getNbThreads() The number of parallel import.
ParallelImportPolicy	makeCopy() Creates and returns a deep copy of this ParallelImportPolicy.
static ParallelImportPolicy	readFrom(java.io.InputStream is) Read this ParallelImportPolicy from an XML fragment.
void	setNbThreads(int nbThreads) The number of parallel import.
java.lang.String	toString() String representation of this ParallelImportPolicy.
ParallelImportPolicy	withNbThreads(int nbThreads)
ParallelImportPolicy	withNbThreads(java.lang.Integer nbThreads)
void	writeTo(java.io.OutputStream os) Write this ParallelImportPolicy as an XML fragment

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

ParallelImportPolicy

public ParallelImportPolicy()

ParallelImportPolicy

public ParallelImportPolicy(ParallelImportPolicy o)

Copy constructor

Method Detail

setNbThreads

public void setNbThreads(int nbThreads)

The number of parallel import.

getNbThreads

public int getNbThreads()

The number of parallel import.

withNbThreads

public ParallelImportPolicy withNbThreads(int nbThreads)

withNbThreads

public ParallelImportPolicy withNbThreads(java.lang.Integer nbThreads)

makeCopy

public ParallelImportPolicy makeCopy()

Creates and returns a deep copy of this ParallelImportPolicy.

Overrides:

makeCopy in class ImportPolicy

readFrom

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

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

Overrides:

writeTo in class ImportPolicy

Throws:

javax.xml.bind.JAXBException

java.io.IOException

fromString

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

String representation of this ParallelImportPolicy.

Throws:

javax.xml.bind.JAXBException

java.io.UnsupportedEncodingException

toString

public java.lang.String toString()

String representation of this ParallelImportPolicy.

Overrides:

toString in class ImportPolicy

check

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

Checks this ParallelImportPolicy.

Specified by:

check in interface com.exalead.util.Checkable

Overrides:

check in class ImportPolicy

Throws:

com.exalead.util.TypedException

accept

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

Specified by:

accept in class ImportPolicy

Throws:

com.exalead.util.TypedException

accept

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

Specified by:

accept in class ImportPolicy

Throws:

com.exalead.util.TypedException