com.neurosys.odb.object.etl

Class ODBPersistTransformer<E,T>

java.lang.Object

com.neurosys.odb.object.etl.ODBPersistTransformer<E,T>

Type Parameters:

E - type of entity

All Implemented Interfaces:

UpdatableContext<com.orientechnologies.orient.core.db.OPartitionedDatabasePool>, Serializable, Function<E,T>, org.apache.commons.collections.Transformer

public class ODBPersistTransformer<E,T>
extends Object
implements UpdatableContext<com.orientechnologies.orient.core.db.OPartitionedDatabasePool>, org.apache.commons.collections.Transformer, Function<E,T>

Object persisting Transformer

Author:

Nitin Sharma, Anubhav Bhargava, Arjun Dhar

See Also:

connectionPool, Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected String	clusterName Will specify cluster in which document is to be persisted
protected com.orientechnologies.orient.core.db.OPartitionedDatabasePool	connectionPool
protected List<RegisterClass>	registerClasses

Constructor Summary

Constructors

Constructor and Description
ODBPersistTransformer()
ODBPersistTransformer(ODBPersistTransformer t)

Method Summary

Modifier and Type	Method and Description
T	apply(E input)
String	getClusterName() Will specify cluster in which document is to be persisted
com.orientechnologies.orient.core.db.OPartitionedDatabasePool	getConnectionPool()
List<RegisterClass>	getRegisterClasses()
void	setClusterName(String clusterName) Will specify cluster in which document is to be persisted
void	setConnectionPool(com.orientechnologies.orient.core.db.OPartitionedDatabasePool connectionPool)
void	setRegisterClasses(List<RegisterClass> registerClasses)
Object	transform(Object input)
void	updateContext(com.orientechnologies.orient.core.db.OPartitionedDatabasePool odbConnectionPool)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Field Detail

connectionPool

protected transient com.orientechnologies.orient.core.db.OPartitionedDatabasePool connectionPool

clusterName

protected String clusterName

Will specify cluster in which document is to be persisted

Can be null:

true

registerClasses

protected List<RegisterClass> registerClasses

Constructor Detail

ODBPersistTransformer

public ODBPersistTransformer()

ODBPersistTransformer

public ODBPersistTransformer(ODBPersistTransformer t)

Method Detail

transform

public Object transform(Object input)

Specified by:

transform in interface org.apache.commons.collections.Transformer

getClusterName

public String getClusterName()

Will specify cluster in which document is to be persisted

Can be null:

true

setClusterName

public void setClusterName(String clusterName)

Will specify cluster in which document is to be persisted

Can be null:

true

getRegisterClasses

public List<RegisterClass> getRegisterClasses()

Returns:

the registerClasses

setRegisterClasses

public void setRegisterClasses(List<RegisterClass> registerClasses)

Parameters:

registerClasses - the registerClasses to set

getConnectionPool

public com.orientechnologies.orient.core.db.OPartitionedDatabasePool getConnectionPool()

setConnectionPool

public void setConnectionPool(com.orientechnologies.orient.core.db.OPartitionedDatabasePool connectionPool)

apply

public T apply(E input)

Specified by:

apply in interface Function<E,T>

updateContext

public void updateContext(com.orientechnologies.orient.core.db.OPartitionedDatabasePool odbConnectionPool)

Specified by:

updateContext in interface UpdatableContext<com.orientechnologies.orient.core.db.OPartitionedDatabasePool>