com.chemaxon.overlap.cli.util.importing

Class ParsedUnguardedResultHandler<T extends Serializable>

java.lang.Object

com.chemaxon.overlap.cli.util.importing.ParsedUnguardedResultHandler<T>

Type Parameters:

T - Unguarded type

All Implemented Interfaces:

ErrorHandler<Object>, ResultHandler<Object,ParsedUnguardedResult<T>>

public final class ParsedUnguardedResultHandler<T extends Serializable>
extends Object
implements ResultHandler<Object,ParsedUnguardedResult<T>>, ErrorHandler<Object>

Results handler for parsed Descriptors. Note that callback methods are invoked from the main thread in the order of inputs. Note that source type is set to Object.

Constructor Summary

Constructors

Constructor and Description
ParsedUnguardedResultHandler(int pagesize, boolean storeIds, boolean failOnError) Create new handler.

Method Summary

Modifier and Type	Method and Description
long	error(int sourceIndex, Object s, Throwable t) Process error report.
MasterStringStorage	getIds() Get collected IDs.
IndexProjector	getIndexProjector() Get ID projection for pages.
ImmutableList<ImmutableList<T>>	getPages() Get collected pages.
boolean	isIdCollected() Check if IDs were collected.
long	result(int sourceIndex, Object s, ParsedUnguardedResult<T> t) Report process result.

Methods inherited from class java.lang.Object

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

Constructor Detail

ParsedUnguardedResultHandler

public ParsedUnguardedResultHandler(int pagesize,
                                    boolean storeIds,
                                    boolean failOnError)

Create new handler.

Parameters:

pagesize - Page size to use

storeIds - When true IDs are stored;

failOnError - If true a reported error will cause an exception in results processing; otherwise a missing ID/skip in index projector will be used

Method Detail

error

public long error(int sourceIndex,
                  Object s,
                  Throwable t)

Description copied from interface: ErrorHandler

Process error report.

Specified by:

error in interface ErrorHandler<Object>

Parameters:

sourceIndex - Index (0-based) of the source structure (input) provoked this error

s - Source caused the reported error

t - The error thrown

Returns:

Work units to be reported

result

public long result(int sourceIndex,
                   Object s,
                   ParsedUnguardedResult<T> t)

Description copied from interface: ResultHandler

Report process result.

Specified by:

result in interface ResultHandler<Object,ParsedUnguardedResult<T extends Serializable>>

Parameters:

sourceIndex - 0-based index of the processed source

s - The processed source

t - The result

Returns:

Number of work units to be reported

getIds

public MasterStringStorage getIds()

Get collected IDs.

Returns:

IDs

Throws:

IllegalStateException - when no IDs were collected

isIdCollected

public boolean isIdCollected()

Check if IDs were collected.

Returns:

true when IDs were collected

getPages

public ImmutableList<ImmutableList<T>> getPages()

Get collected pages.

Returns:

Collected pages

getIndexProjector

public IndexProjector getIndexProjector()

Get ID projection for pages.

Returns:

ID projection