Package com.orientechnologies.orient.etl.loader

Class OETLOrientDBLoader

java.lang.Object

com.orientechnologies.orient.etl.OETLAbstractComponent

com.orientechnologies.orient.etl.loader.OETLAbstractLoader

com.orientechnologies.orient.etl.loader.OETLOrientDBLoader

All Implemented Interfaces:

OETLLoader, OETLComponent, AutoCloseable

public class OETLOrientDBLoader
extends OETLAbstractLoader

ETL Loader that saves record into OrientDB database.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static enum	OETLOrientDBLoader.DB_TYPE

Field Summary

Fields

Modifier and Type	Field	Description
protected int	batchCommitSize
protected AtomicLong	batchCounter
protected String	className
protected String	clusterName
protected boolean	dbAutoCreate
protected boolean	dbAutoCreateProperties
protected boolean	dbAutoDropIfExists
protected String	dbPassword
protected OETLOrientDBLoader.DB_TYPE	dbType
protected String	dbURL
protected String	dbUser
protected static final String	NOT_DEF
OrientDB	orient
ODatabasePool	pool
protected OClass	schemaClass
protected String	serverPassword
protected String	serverUser
protected boolean	skipDuplicates
protected boolean	standardElementConstraints
protected boolean	tx
protected boolean	txUseLog
protected boolean	useLightweightEdges
protected boolean	wal

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

progress

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

configuration, context, ifExpression, output, processor

Constructor Summary

Constructors

Constructor	Description
OETLOrientDBLoader()

Method Summary

Modifier and Type	Method	Description
protected void	autoCreateProperties(ODatabaseDocument db, Object input)
protected void	autoCreatePropertiesOnDocument(ODatabaseDocument db, ODocument doc)
protected void	autoCreatePropertiesOnElement(ODatabaseDocument db, OVertex element)
void	begin(ODatabaseDocument db)
void	beginLoader(OETLPipeline pipeline)
void	close()
void	configure(ODocument conf, OCommandContext iContext)	Called by the @OETLProcessor
protected void	createProperty(OClass cls, String f, Object fValue)
void	end()
ODocument	getConfiguration()
protected ODatabasePool	getDatabasePool()
String	getName()	Return the symbolic name of the component
protected OClass	getOrCreateClass(ODatabaseDocument db, String iClassName, String iSuperClass)
ODatabasePool	getPool()
String	getUnit()
void	load(ODatabaseDocument db, Object input, OCommandContext context)
void	rollback(ODatabaseDocument db)

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

getProgress

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

debug, error, error, format, getCommonConfigurationParameters, getContext, getIfFilter, getProcessor, info, resolve, setProcessor, skip, stringArray2Json, toString, warn

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

getContext, getProcessor, setProcessor

Field Details

NOT_DEF

protected static final String NOT_DEF

See Also:

• Constant Field Values

pool

public ODatabasePool pool

orient

public OrientDB orient

clusterName

protected String clusterName

className

protected String className

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 OETLOrientDBLoader.DB_TYPE dbType

wal

protected boolean wal

txUseLog

protected boolean txUseLog

skipDuplicates

protected boolean skipDuplicates

Constructor Details

OETLOrientDBLoader

public OETLOrientDBLoader()

Method Details

getPool

public ODatabasePool getPool()

load

public void load(ODatabaseDocument db,
 Object input,
 OCommandContext context)

autoCreateProperties

protected void autoCreateProperties(ODatabaseDocument db,
 Object input)

autoCreatePropertiesOnElement

protected void autoCreatePropertiesOnElement(ODatabaseDocument db,
 OVertex element)

autoCreatePropertiesOnDocument

protected void autoCreatePropertiesOnDocument(ODatabaseDocument db,
 ODocument doc)

getUnit

public String getUnit()

rollback

public void rollback(ODatabaseDocument db)

getOrCreateClass

protected OClass getOrCreateClass(ODatabaseDocument db,
 String iClassName,
 String iSuperClass)

createProperty

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

getConfiguration

public ODocument getConfiguration()

Specified by:

getConfiguration in interface OETLComponent

Overrides:

getConfiguration in class OETLAbstractComponent

Returns:

configure

public void configure(ODocument conf,
 OCommandContext iContext)

Description copied from interface: OETLComponent

Called by the @OETLProcessor

Specified by:

configure in interface OETLComponent

Overrides:

configure in class OETLAbstractComponent

begin

public void begin(ODatabaseDocument db)

Specified by:

begin in interface OETLComponent

Overrides:

begin in class OETLAbstractComponent

beginLoader

public void beginLoader(OETLPipeline pipeline)

Specified by:

beginLoader in interface OETLLoader

Overrides:

beginLoader in class OETLAbstractLoader

getDatabasePool

protected ODatabasePool getDatabasePool()

end

public void end()

Specified by:

end in interface OETLComponent

Overrides:

end in class OETLAbstractComponent

close

public void close()

getName

public String getName()

Description copied from interface: OETLComponent

Return the symbolic name of the component

Returns:

the name of the component