com.orientechnologies.orient.etl.loader

Class OStreamLoader

java.lang.Object

com.orientechnologies.orient.etl.OAbstractETLComponent

com.orientechnologies.orient.etl.loader.OAbstractLoader

com.orientechnologies.orient.etl.loader.OStreamLoader

All Implemented Interfaces:

OLoader, OETLComponent

public class OStreamLoader
extends OAbstractLoader

Loader implementation based on events. It allows to stream data from the an ETL process and work with the transformed data in real-time without storing the data anywhere.

Author:

Luca Garulli

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	OStreamLoader.Listener

Field Summary

Fields inherited from class com.orientechnologies.orient.etl.loader.OAbstractLoader

progress

Fields inherited from class com.orientechnologies.orient.etl.OAbstractETLComponent

context, ifExpression, logLevel, output, processor

Constructor Summary

Constructors

Constructor and Description
OStreamLoader()

Method Summary

Modifier and Type	Method and Description
String	getName() Return the symbolic name of the component
String	getUnit()
void	load(OETLPipeline pipeline, Object input, OCommandContext context)
void	registerListener(OStreamLoader.Listener listener)
void	rollback(OETLPipeline pipeline)

Methods inherited from class com.orientechnologies.orient.etl.loader.OAbstractLoader

beginLoader, endLoader, getProgress

Methods inherited from class com.orientechnologies.orient.etl.OAbstractETLComponent

begin, configure, end, getCommonConfigurationParameters, getConfiguration, getIfFilter, log, resolve, skip, stringArray2Json, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.etl.OETLComponent

begin, configure, end, getConfiguration

Constructor Detail

OStreamLoader

public OStreamLoader()

Method Detail

registerListener

public void registerListener(OStreamLoader.Listener listener)

load

public void load(OETLPipeline pipeline,
                 Object input,
                 OCommandContext context)

getUnit

public String getUnit()

rollback

public void rollback(OETLPipeline pipeline)

getName

public String getName()

Description copied from interface: OETLComponent

Return the symbolic name of the component

Returns:

the name of the component