com.neurosys.ecom.etl

Class AreaPersistTransformer<A extends Area>

java.lang.Object

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

com.neurosys.ecom.etl.AreaPersistTransformer<A>

All Implemented Interfaces:

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

public class AreaPersistTransformer<A extends Area>
extends EntityPersistTransformer<A>

Persist Area and return the Persisted Entity

Author:

Arjun Dhar

Field Summary

Fields

Modifier and Type	Field and Description
protected LogisticsService	service

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

em, exceptions, failFast, messages, tm

Constructor Summary

Constructors

Constructor and Description
AreaPersistTransformer()

Method Summary

Modifier and Type	Method and Description
LogisticsService	getService()
void	setService(LogisticsService service)
A	write(A record) Write a record
Collection<A>	write(Collection<A> input) Write a Buffer of records at a given time.

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

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

Methods inherited from class java.lang.Object

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

Field Detail

service

protected LogisticsService service

Constructor Detail

AreaPersistTransformer

public AreaPersistTransformer()

Method Detail

getService

public LogisticsService getService()

setService

public void setService(LogisticsService service)

write

@Transactional(readOnly=false)
public Collection<A> write(Collection<A> 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<A extends Area>

Overrides:

write in class EntityPersistTransformer<A extends Area>

Parameters:

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

write

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

Description copied from interface: RealTimeWriter

Write a record

Specified by:

write in interface RealTimeWriter<A extends Area>

Overrides:

write in class EntityPersistTransformer<A extends Area>