Package 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	Description
protected final OCommandContext	context
protected boolean	haltOnError
protected final OETLLoader	loader
protected final Level	logLevel
protected final int	maxRetries
protected ODatabasePool	pool
protected final OETLProcessor	processor
protected final List<OETLTransformer>	transformers

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected ODatabaseDocument	acquire()
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 Details

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 Details

OETLPipeline

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

Method Details

begin

public void begin()

setPool

public void setPool(ODatabasePool pool)

getContext

public OCommandContext getContext()

acquire

protected ODatabaseDocument acquire()

execute

protected Object execute(OETLExtractedItem source)

end

public void end()