SimpleEtl (Moqui Framework 3.0.0)

org.moqui.etl.SimpleEtl

@java.lang.SuppressWarnings("unused")
public class SimpleEtl
extends java.lang.Object

Nested Class Summary

Nested classes
Modifiers	Name	Description
`interface`	`SimpleEtl.Entry`
`static class`	`SimpleEtl.EntryTransform`
`static class`	`SimpleEtl.EtlError`
`interface`	`SimpleEtl.Extractor`
`interface`	`SimpleEtl.Loader`
`static class`	`SimpleEtl.SimpleEntry`
`static class`	`SimpleEtl.StopException`
`static class`	`SimpleEtl.TransformConfiguration`
`interface`	`SimpleEtl.Transformer`	Stateless ETL entry transformer and filter interface

Constructor Summary

Constructors
Constructor and description
`SimpleEtl (SimpleEtl.Extractor extractor, SimpleEtl.Loader loader)`

Methods Summary

Methods
Type Params	Return Type	Name and description
	`public SimpleEtl`	`addConfiguration(SimpleEtl.TransformConfiguration config)` Add from an external TransformConfiguration, copies configuration to avoid modification
	`public SimpleEtl`	`addMessage(java.lang.String msg)`
	`public SimpleEtl`	`addTransformer(SimpleEtl.Transformer transformer)` Call this to add a transformer to run for any type, will be run in order added
	`public SimpleEtl`	`addTransformer(java.lang.String type, SimpleEtl.Transformer transformer)` Call this to add a transformer to run a particular type, which will be run in order for entries of the type
	`public int`	`getExtractCount()`
	`public java.lang.Exception`	`getExtractException()`
	`public SimpleEtl.Extractor`	`getExtractor()`
	`public int`	`getLoadCount()`
	`public java.util.List<EtlError>`	`getLoadErrors()`
	`public SimpleEtl.Loader`	`getLoader()`
	`public java.util.List<java.lang.String>`	`getMessages()`
	`public long`	`getRunTime()`
	`public java.lang.Throwable`	`getSingleErrorCause()`
	`public int`	`getSkipCount()`
	`public java.util.List<EtlError>`	`getTransformErrors()`
	`public boolean`	`hasError()`
	`public SimpleEtl`	`process()` Call this to process the ETL
	`public boolean`	`processEntry(SimpleEtl.Entry extractEntry)` Called by the Extractor to process an extracted entry.
	`public SimpleEtl`	`setConfiguration(SimpleEtl.TransformConfiguration config)` Use an external configuration as-is.
	`public SimpleEtl`	`setTimeout(java.lang.Integer timeout)` Set timeout in seconds; passed to Loader.init() for transactions, etc
	`public SimpleEtl`	`stopOnError()` Call this to set stop on error flag

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class java.lang.Object`	`java.lang.Object#wait(long), java.lang.Object#wait(long, int), java.lang.Object#wait(), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()`

- Constructor Detail
  - public SimpleEtl(@javax.annotation.Nonnull SimpleEtl.Extractor extractor, @javax.annotation.Nonnull SimpleEtl.Loader loader)
- Method Detail
  - public SimpleEtl addConfiguration(SimpleEtl.TransformConfiguration config)
    
    Add from an external TransformConfiguration, copies configuration to avoid modification
  - public SimpleEtl addMessage(java.lang.String msg)
  - public SimpleEtl addTransformer(@javax.annotation.Nonnull SimpleEtl.Transformer transformer)
    
    Call this to add a transformer to run for any type, will be run in order added
  - public SimpleEtl addTransformer(@javax.annotation.Nonnull java.lang.String type, @javax.annotation.Nonnull SimpleEtl.Transformer transformer)
    
    Call this to add a transformer to run a particular type, which will be run in order for entries of the type
  - public int getExtractCount()
  - public java.lang.Exception getExtractException()
  - public SimpleEtl.Extractor getExtractor()
  - public int getLoadCount()
  - public java.util.List<EtlError> getLoadErrors()
  - public SimpleEtl.Loader getLoader()
  - public java.util.List<java.lang.String> getMessages()
  - public long getRunTime()
  - public java.lang.Throwable getSingleErrorCause()
  - public int getSkipCount()
  - public java.util.List<EtlError> getTransformErrors()
  - public boolean hasError()
  - public SimpleEtl process()
    
    Call this to process the ETL
  - public boolean processEntry(SimpleEtl.Entry extractEntry)
    
    Called by the Extractor to process an extracted entry.
    throws:
    StopException if thrown extraction should stop and return
    
    Returns:
    true if the entry loaded, false otherwise
  - public SimpleEtl setConfiguration(SimpleEtl.TransformConfiguration config)
    
    Use an external configuration as-is. Overrides any previous addTransformer() and addConfiguration() calls. Any calls to addTransformer() and addConfiguration() will modify this configuration.
  - public SimpleEtl setTimeout(java.lang.Integer timeout)
    
    Set timeout in seconds; passed to Loader.init() for transactions, etc
  - public SimpleEtl stopOnError()
    
    Call this to set stop on error flag

Summary:
Nested
Constructor
Method

| Detail:
Constructor
Method

Groovy Documentation

[Java] Class SimpleEtl

Nested Class Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Constructor Detail

public SimpleEtl(@javax.annotation.Nonnull SimpleEtl.Extractor extractor, @javax.annotation.Nonnull SimpleEtl.Loader loader)

Method Detail

public SimpleEtl addConfiguration(SimpleEtl.TransformConfiguration config)

public SimpleEtl addMessage(java.lang.String msg)

public SimpleEtl addTransformer(@javax.annotation.Nonnull SimpleEtl.Transformer transformer)

public SimpleEtl addTransformer(@javax.annotation.Nonnull java.lang.String type, @javax.annotation.Nonnull SimpleEtl.Transformer transformer)

public int getExtractCount()

public java.lang.Exception getExtractException()

public SimpleEtl.Extractor getExtractor()

public int getLoadCount()

public java.util.List<EtlError> getLoadErrors()

public SimpleEtl.Loader getLoader()

public java.util.List<java.lang.String> getMessages()

public long getRunTime()

public java.lang.Throwable getSingleErrorCause()

public int getSkipCount()

public java.util.List<EtlError> getTransformErrors()

public boolean hasError()

public SimpleEtl process()

public boolean processEntry(SimpleEtl.Entry extractEntry)

public SimpleEtl setConfiguration(SimpleEtl.TransformConfiguration config)

public SimpleEtl setTimeout(java.lang.Integer timeout)

public SimpleEtl stopOnError()