com.orientechnologies.orient.etl

Class OETLPipeline

java.lang.Object

com.orientechnologies.orient.etl.OETLPipeline

public class OETLPipeline
extends Object

ETL pipeline: sequence of OETLTransformer and a OETLLoader.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com) (l.garulli-at-orientdb.com)

Field Summary

Fields

Modifier and Type	Field and Description
protected OCommandContext	context
protected boolean	haltOnError
protected OETLLoader	loader
protected Level	logLevel
protected int	maxRetries
protected ODatabasePool	pool
protected OETLProcessor	processor
protected List<OETLTransformer>	transformers

Constructor Summary

Constructors

Constructor and Description
OETLPipeline(OETLProcessor processor, List<OETLTransformer> transformers, OETLLoader loader, Level logLevel, int maxRetries, boolean haltOnError)

Method Summary

Modifier and Type	Method and Description
void	begin()
void	end()
protected Object	execute(OETLExtractedItem source)
OCommandContext	getContext()
void	setPool(ODatabasePool pool)

Methods inherited from class java.lang.Object

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

Field Detail

processor

protected final OETLProcessor processor

transformers

protected final List<OETLTransformer> transformers

loader

protected final OETLLoader loader

context

protected final OCommandContext context

logLevel

protected final Level logLevel

maxRetries

protected final int maxRetries

haltOnError

protected boolean haltOnError

pool

protected ODatabasePool pool

Constructor Detail

OETLPipeline

public OETLPipeline(OETLProcessor processor,
                    List<OETLTransformer> transformers,
                    OETLLoader loader,
                    Level logLevel,
                    int maxRetries,
                    boolean haltOnError)

Method Detail

begin

public void begin()

setPool

public void setPool(ODatabasePool pool)

getContext

public OCommandContext getContext()

execute

protected Object execute(OETLExtractedItem source)

end

public void end()