com.orientechnologies.orient.etl

Class OAbstractETLComponent

java.lang.Object

com.orientechnologies.orient.etl.OAbstractETLComponent

All Implemented Interfaces:

OETLComponent

Direct Known Subclasses:

OAbstractBlock, OAbstractETLPipelineComponent, OAbstractExtractor, OAbstractLoader, OAbstractSource

public abstract class OAbstractETLComponent
extends Object
implements OETLComponent

ETL abstract component.

Field Summary

Fields

Modifier and Type	Field and Description
protected OCommandContext	context
protected String	ifExpression
protected OETLProcessor.LOG_LEVELS	logLevel
protected String	output
protected OETLProcessor	processor

Constructor Summary

Constructors

Constructor and Description
OAbstractETLComponent()

Method Summary

Modifier and Type	Method and Description
void	begin()
void	configure(OETLProcessor iProcessor, ODocument iConfiguration, OCommandContext iContext) Called by the @OETLProcessor
void	end()
protected String	getCommonConfigurationParameters()
ODocument	getConfiguration()
protected OSQLFilter	getIfFilter()
protected void	log(OETLProcessor.LOG_LEVELS iLevel, String iText, Object... iArgs)
protected Object	resolve(Object iContent)
protected boolean	skip(Object input)
protected String	stringArray2Json(Object[] iObject)
String	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

getName

Field Detail

processor

protected OETLProcessor processor

context

protected OCommandContext context

logLevel

protected OETLProcessor.LOG_LEVELS logLevel

output

protected String output

ifExpression

protected String ifExpression

Constructor Detail

OAbstractETLComponent

public OAbstractETLComponent()

Method Detail

getConfiguration

public ODocument getConfiguration()

Specified by:

getConfiguration in interface OETLComponent

Returns:

configure

public void configure(OETLProcessor iProcessor,
                      ODocument iConfiguration,
                      OCommandContext iContext)

Description copied from interface: OETLComponent

Called by the @OETLProcessor

Specified by:

configure in interface OETLComponent

begin

public void begin()

Specified by:

begin in interface OETLComponent

end

public void end()

Specified by:

end in interface OETLComponent

getCommonConfigurationParameters

protected String getCommonConfigurationParameters()

toString

public String toString()

Overrides:

toString in class Object

skip

protected boolean skip(Object input)

getIfFilter

protected OSQLFilter getIfFilter()

log

protected void log(OETLProcessor.LOG_LEVELS iLevel,
                   String iText,
                   Object... iArgs)

stringArray2Json

protected String stringArray2Json(Object[] iObject)

resolve

protected Object resolve(Object iContent)