com.neurosys.etl.common.transformers

Class AsynchronousTransformer

java.lang.Object

com.neurosys.etl.common.transformers.AsynchronousTransformer

All Implemented Interfaces:

FunctionTransformer, Function, org.apache.commons.collections.Transformer

public class AsynchronousTransformer
extends Object
implements FunctionTransformer

Asynchronously forms off the transformation process in parallel; when it finishes it calls a #listener as a callback with the final output.

Author:

Arjun Dhar

Constructor Summary

Constructors

Constructor and Description
AsynchronousTransformer()

Method Summary

Modifier and Type	Method and Description
org.apache.commons.collections.Transformer	getCallback() Callback to the end of the asynchronous process
org.apache.commons.collections.Transformer	getProcessor() The Transformer that will be called in a separate thread with the original input as input to it.
boolean	isSingleThread() If true it will execute it as part of the original thread sequentially, but the process is still forked from original
void	setCallback(org.apache.commons.collections.Transformer callback) Callback to the end of the asynchronous process
void	setProcessor(org.apache.commons.collections.Transformer processor) The Transformer that will be called in a separate thread with the original input as input to it.
void	setSingleThread(boolean singleThread) If true it will execute it as part of the original thread sequentially, but the process is still forked from original
Object	transform(Object input)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.neurosys.etl.common.transformers.FunctionTransformer

apply

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Constructor Detail

AsynchronousTransformer

public AsynchronousTransformer()

Method Detail

transform

public Object transform(Object input)

Specified by:

transform in interface org.apache.commons.collections.Transformer

getCallback

public org.apache.commons.collections.Transformer getCallback()

Callback to the end of the asynchronous process

Can be null:

true

setCallback

public void setCallback(org.apache.commons.collections.Transformer callback)

Callback to the end of the asynchronous process

Can be null:

true

getProcessor

public org.apache.commons.collections.Transformer getProcessor()

The Transformer that will be called in a separate thread with the original input as input to it.

setProcessor

public void setProcessor(org.apache.commons.collections.Transformer processor)

The Transformer that will be called in a separate thread with the original input as input to it.

isSingleThread

public boolean isSingleThread()

If true it will execute it as part of the original thread sequentially, but the process is still forked from original

Default value:

false

setSingleThread

public void setSingleThread(boolean singleThread)

If true it will execute it as part of the original thread sequentially, but the process is still forked from original

Default value:

false