Package com.neurosys.etl.common

Interface Summary

Interface	Description
AccessorLookUp	A consistent way to ensure a processor can take an entity and use the key to lookup a value from it.
Chain<T,O>	Defines a chain of processors
ChainAware<T,O>	Processors, Lookup, Predicate or Transformer that are aware that they are being called in a Chain
ContextAware<CONTEXT>	A Context aware interface that will expect(prefer) a context as an input in an ETL process.
EntityFieldSetter<E,V>	Substitute for PropertyUtils(Object, String, Object) or BeanUtils#setProperty(Object, String, Object) for instances that cannot be set by it due to various reasons.
FailFastAware	If the class is aware that it should fail fase (quit) @ the first sign of a problem
IdempotentAware	A Reader, Transformer or Mapper is aware that the process is only to verify the process than make any permanent changes. If #isIdemponent() is true, all operations are idempotent.
Identifiable<T>	Any process thats identifiable
Lookup	Support Lookups during the ETL Process; useful when mapping Fields
ModeAware	A Reader, Transformer or Mapper is aware of an update mode.
Mutate<T>	Mutates an object of type T, to merge its values into the input (parent) object and produce a resultant Object of type T. The resultant object is implementation dependent if its an existing modified object or a clone modified.
ParamsAware	If the class is aware that it can accept parameters
ReaderAware<TUPLE_IN,RECORD_OUT,STATE,R extends BaseIterativeProcessor<TUPLE_IN,RECORD_OUT,STATE>>	Processor or Transformer is AbstractReader or BaseIterativeProcessor aware.
Sender<PAYLOAD,RECIPIENT>	A generic way to send data
SerializableTransformer	A Serializable Transformer
SourceAware	A marker interface that signifies that the Process will require a file/Source upload that is ModeAware
UsesIntermediateObject<CONTEXT>	A Transformer, Predicate, Lookup or Chain that uses an IntermediateResultMapperBehaviors result(s). A process that recognized this type of instance will #setIntermediateResults(Map)

Class Summary

Class	Description
DefaultExistingEntityLookup<E>	ExistingEntityLookup for any Entity that can be found using a #fin
ETLMeta<PARAM_META>	Provide an ETL process with any additional (supplementary) contextual instructions (like UI input) needed for Processing instructions that are not part of the core process. The ETLMeta can be used to pre-process INPUT using ETLMeta.inputParamsMetas or post-process using ETLMeta.entityProcessor, the generated entity from the AbstractReader per tuple.
ExistingEntityLookup<T>	Check to see if an Entity already exists, and if so load (and update) it; based on various other settings provided by this class.
ExistingEntityMergeTransformer<T>	Various settings provided by this class; merge existing entity fields into primary one. Useful when an entity has related entities that need to exist/persist.
FilterChain	Allow chaining of multiple Predicates
LookupChain	Allow chaining of multiple Lookups TransformerChain.isChainOutput() is ignored for this implementation, as lookup operations are sequential and the next depends on previous.
SerializableTransformerChain	Allow chaining of multiple Lookups; and supports Non-Serializable transient Transformers as well so the Chain itself is Serializable
SimpleMapLookup	A Lookup over a Simple HashMap
TransformerChain	Allow chaining of multiple Transformers
TransformerParallel	Allow multiple Transformers to fire independently with the same input.
TransformerToLookup	Wrapper: Convert a Transformer to a Lookup
TransformerToPredicate	Wrapper: Convert a Transformer to a Predicate. If the transformed output is not null it will return true else false.

Enum Summary

Enum	Description
Mode	Mode in which Readers and Mappers can execute
Mutate.Mutation