Package com.orientechnologies.orient.etl
Class OETLPipeline
java.lang.Object
com.orientechnologies.orient.etl.OETLPipeline
ETL pipeline: sequence of OETLTransformer and a OETLLoader.
- Author:
- Luca Garulli (l.garulli--(at)--orientdb.com) (l.garulli-at-orientdb.com)
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final OCommandContextprotected booleanprotected final OETLLoaderprotected final Levelprotected final intprotected ODatabasePoolprotected final OETLProcessorprotected final List<OETLTransformer> -
Constructor Summary
ConstructorsConstructorDescriptionOETLPipeline(OETLProcessor processor, List<OETLTransformer> transformers, OETLLoader loader, Level logLevel, int maxRetries, boolean haltOnError) -
Method Summary
Modifier and TypeMethodDescriptionprotected ODatabaseDocumentacquire()voidbegin()voidend()protected Objectexecute(OETLExtractedItem source) voidsetPool(ODatabasePool pool)
-
Field Details
-
processor
-
transformers
-
loader
-
context
-
logLevel
-
maxRetries
protected final int maxRetries -
haltOnError
protected boolean haltOnError -
pool
-
-
Constructor Details
-
OETLPipeline
public OETLPipeline(OETLProcessor processor, List<OETLTransformer> transformers, OETLLoader loader, Level logLevel, int maxRetries, boolean haltOnError)
-
-
Method Details
-
begin
public void begin() -
setPool
-
getContext
-
acquire
-
execute
-
end
public void end()
-