public interface SimpleEtl.Loader
| Type Params | Return Type | Name and description |
|---|---|---|
|
public void |
complete(SimpleEtl etl)Called after all entries processed to close files, commit/rollback transactions, etc; |
|
public void |
init(java.lang.Integer timeout)Called before SimpleEtl processing begins |
|
public void |
load(SimpleEtl.Entry entry)Load a single, optionally transformed, entry into the data destination |
Called after all entries processed to close files, commit/rollback transactions, etc;
Called before SimpleEtl processing begins
Load a single, optionally transformed, entry into the data destination