com.orientechnologies.orient.etl

Class OETLPipeline

java.lang.Object

com.orientechnologies.orient.etl.OETLPipeline

public class OETLPipeline
extends Object

ETL pipeline: sequence of OTransformer and a OLoader.

Author:

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

Field Summary

Fields

Modifier and Type	Field and Description
protected OCommandContext	context
protected ODatabaseDocument	db
protected OrientBaseGraph	graph
protected boolean	haltOnError
protected OLoader	loader
protected OETLProcessor.LOG_LEVELS	logLevel
protected int	maxRetries
protected OETLProcessor	processor
protected List<OTransformer>	transformers

Constructor Summary

Constructors

Constructor and Description
OETLPipeline(OETLProcessor processor, List<OTransformer> transformers, OLoader loader, OETLProcessor.LOG_LEVELS logLevel, int maxRetries, boolean haltOnError)

Method Summary

Modifier and Type	Method and Description
void	begin()
void	end()
protected Object	execute(OExtractedItem source)
OCommandContext	getContext()
ODatabaseDocument	getDocumentDatabase()
OrientBaseGraph	getGraphDatabase()
OETLPipeline	setDocumentDatabase(ODatabaseDocument iDb)
OETLPipeline	setGraphDatabase(OrientBaseGraph iGraph)

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<OTransformer> transformers

loader

protected final OLoader loader

context

protected final OCommandContext context

logLevel

protected final OETLProcessor.LOG_LEVELS logLevel

maxRetries

protected final int maxRetries

haltOnError

protected boolean haltOnError

db

protected ODatabaseDocument db

graph

protected OrientBaseGraph graph

Constructor Detail

OETLPipeline

public OETLPipeline(OETLProcessor processor,
                    List<OTransformer> transformers,
                    OLoader loader,
                    OETLProcessor.LOG_LEVELS logLevel,
                    int maxRetries,
                    boolean haltOnError)

Method Detail

begin

public void begin()

getDocumentDatabase

public ODatabaseDocument getDocumentDatabase()

setDocumentDatabase

public OETLPipeline setDocumentDatabase(ODatabaseDocument iDb)

getGraphDatabase

public OrientBaseGraph getGraphDatabase()

setGraphDatabase

public OETLPipeline setGraphDatabase(OrientBaseGraph iGraph)

getContext

public OCommandContext getContext()

execute

protected Object execute(OExtractedItem source)

end

public void end()