OETLPipeline (OrientDB 2.2.1-SNAPSHOT API)

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 ODatabaseDocumentTx`	`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

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`begin()`
`void`	`end()`
`protected Object`	`execute(OExtractedItem source)`
`OCommandContext`	`getContext()`
`ODatabaseDocumentTx`	`getDocumentDatabase()`
`OrientBaseGraph`	`getGraphDatabase()`
`OETLPipeline`	`setDocumentDatabase(ODatabaseDocumentTx 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 ODatabaseDocumentTx 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 ODatabaseDocumentTx getDocumentDatabase()

setDocumentDatabase

public OETLPipeline setDocumentDatabase(ODatabaseDocumentTx 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()
```

Class OETLPipeline

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

processor

transformers

loader

context

logLevel

maxRetries

haltOnError

db

graph

Constructor Detail

OETLPipeline

Method Detail

begin

getDocumentDatabase

setDocumentDatabase

getGraphDatabase

setGraphDatabase

getContext

execute

end