com.neurosys.odb.object.etl

Class ODBDetachTransformer<T>

java.lang.Object

com.neurosys.odb.object.etl.ODBDetachTransformer<T>

All Implemented Interfaces:

Function<T,T>, org.apache.commons.collections.Transformer

public class ODBDetachTransformer<T>
extends Object
implements Function<T,T>, org.apache.commons.collections.Transformer

ODB creates Lazy loaded objects connected to the DB. We would need the object detached @ some point so can use this.

TODO: Add unit test case

Author:

Arjun Dhar

Field Summary

Fields

Modifier and Type	Field and Description
protected com.orientechnologies.orient.core.db.OPartitionedDatabasePool	connectionPool Document database Connection Pool

Constructor Summary

Constructors

Constructor and Description
ODBDetachTransformer()

Method Summary

Modifier and Type	Method and Description
T	apply(T input)
protected com.orientechnologies.orient.object.db.OObjectDatabaseTx	getConnection()
com.orientechnologies.orient.core.db.OPartitionedDatabasePool	getConnectionPool()
void	setConnectionPool(com.orientechnologies.orient.core.db.OPartitionedDatabasePool connectionPool)
Object	transform(Object input)

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

Document database Connection Pool

See Also:

ODatabasePool, OPartitionedDatabasePool

Constructor Detail

ODBDetachTransformer

public ODBDetachTransformer()

Method Detail

getConnection

protected com.orientechnologies.orient.object.db.OObjectDatabaseTx getConnection()

transform

public Object transform(Object input)

Specified by:

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

apply

public T apply(T input)

Specified by:

apply in interface Function<T,T>

getConnectionPool

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

setConnectionPool

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