com.orientechnologies.orient.etl.loader

Class OOrientDBLoader

java.lang.Object

com.orientechnologies.orient.etl.OAbstractETLComponent

com.orientechnologies.orient.etl.loader.OAbstractLoader

com.orientechnologies.orient.etl.loader.OOrientDBLoader

All Implemented Interfaces:

OLoader, OETLComponent

public class OOrientDBLoader
extends OAbstractLoader
implements OLoader

ETL Loader that saves record into OrientDB database.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	OOrientDBLoader.DB_TYPE

Field Summary

Fields

Modifier and Type	Field and Description
protected int	batchCommitSize
protected AtomicLong	batchCounter
protected List<ODocument>	classes
protected String	className
protected String	clusterName
protected boolean	dbAutoCreate
protected boolean	dbAutoCreateProperties
protected boolean	dbAutoDropIfExists
protected String	dbPassword
protected OOrientDBLoader.DB_TYPE	dbType
protected String	dbURL
protected String	dbUser
protected List<ODocument>	indexes
protected OClass	schemaClass
protected String	serverPassword
protected String	serverUser
protected boolean	standardElementConstraints
protected boolean	tx
protected boolean	txUseLog
protected boolean	useLightweightEdges
protected boolean	wal

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
OOrientDBLoader()

Method Summary

Modifier and Type	Method and Description
void	begin()
void	beginLoader(OETLPipeline pipeline)
void	configure(OETLProcessor iProcessor, ODocument conf, OCommandContext iContext) Called by the @OETLProcessor
protected void	createProperty(OClass cls, String f, Object fValue)
void	end()
void	endLoader(OETLPipeline pipeline)
ODocument	getConfiguration()
String	getName() Return the symbolic name of the component
protected OClass	getOrCreateClass(OETLPipeline pipeline, String iClassName, String iSuperClass)
String	getUnit()
void	load(OETLPipeline pipeline, Object input, OCommandContext context)
void	rollback(OETLPipeline pipeline)

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

getProgress

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

getCommonConfigurationParameters, 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.loader.OLoader

getProgress

Field Detail

clusterName

protected String clusterName

className

protected String className

classes

protected List<ODocument> classes

indexes

protected List<ODocument> indexes

schemaClass

protected OClass schemaClass

dbURL

protected String dbURL

dbUser

protected String dbUser

dbPassword

protected String dbPassword

serverUser

protected String serverUser

serverPassword

protected String serverPassword

dbAutoCreate

protected boolean dbAutoCreate

dbAutoDropIfExists

protected boolean dbAutoDropIfExists

dbAutoCreateProperties

protected boolean dbAutoCreateProperties

useLightweightEdges

protected boolean useLightweightEdges

standardElementConstraints

protected boolean standardElementConstraints

tx

protected boolean tx

batchCommitSize

protected int batchCommitSize

batchCounter

protected AtomicLong batchCounter

dbType

protected OOrientDBLoader.DB_TYPE dbType

wal

protected boolean wal

txUseLog

protected boolean txUseLog

Constructor Detail

OOrientDBLoader

public OOrientDBLoader()

Method Detail

load

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

Specified by:

load in interface OLoader

getUnit

public String getUnit()

Specified by:

getUnit in interface OLoader

rollback

public void rollback(OETLPipeline pipeline)

Specified by:

rollback in interface OLoader

createProperty

protected void createProperty(OClass cls,
                              String f,
                              Object fValue)

getConfiguration

public ODocument getConfiguration()

Specified by:

getConfiguration in interface OETLComponent

Overrides:

getConfiguration in class OAbstractETLComponent

Returns:

configure

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

Description copied from interface: OETLComponent

Called by the @OETLProcessor

Specified by:

configure in interface OETLComponent

Overrides:

configure in class OAbstractETLComponent

begin

public void begin()

Specified by:

begin in interface OETLComponent

Overrides:

begin in class OAbstractETLComponent

end

public void end()

Specified by:

end in interface OETLComponent

Overrides:

end in class OAbstractETLComponent

beginLoader

public void beginLoader(OETLPipeline pipeline)

Specified by:

beginLoader in interface OLoader

Overrides:

beginLoader in class OAbstractLoader

getOrCreateClass

protected OClass getOrCreateClass(OETLPipeline pipeline,
                                  String iClassName,
                                  String iSuperClass)

getName

public String getName()

Description copied from interface: OETLComponent

Return the symbolic name of the component

Specified by:

getName in interface OETLComponent

Returns:

the name of the component

endLoader

public void endLoader(OETLPipeline pipeline)

Specified by:

endLoader in interface OLoader

Overrides:

endLoader in class OAbstractLoader