com.neurosys.modules.etl

Class ProductPersistTransformer<P extends Product>

java.lang.Object

com.neurosys.modules.etl.EntityPersistTransformer<P>

com.neurosys.modules.etl.ProductPersistTransformer<P>

All Implemented Interfaces:

FailFastAware, RealTimeWriter<P>, Writer, org.apache.commons.collections.Transformer

Direct Known Subclasses:

ModeAwareProductPersistTransformer, ProductPersistTransformer

public class ProductPersistTransformer<P extends Product>
extends EntityPersistTransformer<P>

Persist a Product/Product(s) and return the Persisted Entity

Author:

Arjun Dhar

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	allowMultipleParents While inserting a record, if the record already exists and has a legitimate parent, then create a ProductAlias for it
protected ProductService<P>	productService

Fields inherited from class com.neurosys.modules.etl.EntityPersistTransformer

em, exceptions, failFast, messages, tm

Constructor Summary

Constructors

Constructor and Description
ProductPersistTransformer()

Method Summary

Modifier and Type	Method and Description
protected Object	getId(P entity)
protected P	getNewProduct()
ProductService<P>	getProductService()
org.springframework.transaction.TransactionDefinition	getTransactionDef()
boolean	isAllowMultipleParents() While inserting a record, if the record already exists and has a legitimate parent, then create a ProductAlias for it
protected boolean	saveProductAlias(P p) Handle the process of creating/updating a ProductAlias Create an Alias for a request of parent Hierarchy that is different that an existing one only else reject the request
void	setAllowMultipleParents(boolean allowMultipleParents) While inserting a record, if the record already exists and has a legitimate parent, then create a ProductAlias for it
void	setProductService(ProductService<P> productService)
void	setTransactionDef(org.springframework.transaction.TransactionDefinition transactionDef)
Collection<P>	write(Collection<P> input) Write a Buffer of records at a given time.
P	write(P record) Write a record

Methods inherited from class com.neurosys.modules.etl.EntityPersistTransformer

close, getExceptions, getMessages, handleException, init, isExecuteUnderTransaction, isFailFast, isInitialized, setExceptions, setExecuteUnderTransaction, setFailFast, setMessages, transform

Methods inherited from class java.lang.Object

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

Field Detail

productService

protected ProductService<P extends Product> productService

allowMultipleParents

protected boolean allowMultipleParents

While inserting a record, if the record already exists and has a legitimate parent, then create a ProductAlias for it

Default value:

false

Constructor Detail

ProductPersistTransformer

public ProductPersistTransformer()

Method Detail

getProductService

public ProductService<P> getProductService()

setProductService

public void setProductService(ProductService<P> productService)

getNewProduct

protected P getNewProduct()

getId

protected Object getId(P entity)

saveProductAlias

protected boolean saveProductAlias(P p)

Handle the process of creating/updating a ProductAlias
Create an Alias for a request of parent Hierarchy that is different that an existing one only else reject the request

Parameters:

p - as Product; non-committed version from the ETL. It may not have an Product.getId() and it may have a different parent need than the one existing already

Returns:

boolean. If true means the creation of Alias is legitimate else if its rejected will return false

write

@Transactional(readOnly=false)
public Collection<P> write(Collection<P> input)

Description copied from interface: RealTimeWriter

Write a Buffer of records at a given time. Multiple write() may be called in sequence to append to end Sink/File.

Specified by:

write in interface RealTimeWriter<P extends Product>

Overrides:

write in class EntityPersistTransformer<P extends Product>

Parameters:

input - as Collection of records to be written to sink.

write

@Transactional(readOnly=false)
public P write(P record)

Description copied from interface: RealTimeWriter

Write a record

Specified by:

write in interface RealTimeWriter<P extends Product>

Overrides:

write in class EntityPersistTransformer<P extends Product>

isAllowMultipleParents

public boolean isAllowMultipleParents()

While inserting a record, if the record already exists and has a legitimate parent, then create a ProductAlias for it

Default value:

false

setAllowMultipleParents

public void setAllowMultipleParents(boolean allowMultipleParents)

While inserting a record, if the record already exists and has a legitimate parent, then create a ProductAlias for it

Default value:

false

getTransactionDef

public org.springframework.transaction.TransactionDefinition getTransactionDef()

Overrides:

getTransactionDef in class EntityPersistTransformer<P extends Product>

See Also:

EntityPersistTransformer.executeUnderTransaction

setTransactionDef

public void setTransactionDef(org.springframework.transaction.TransactionDefinition transactionDef)

Overrides:

setTransactionDef in class EntityPersistTransformer<P extends Product>

See Also:

EntityPersistTransformer.executeUnderTransaction