This project has retired. For details please refer to its Attic page.

org.apache.oozie.executor.jpa.sla
Class SLACalculationInsertUpdateJPAExecutor

java.lang.Object
  org.apache.oozie.executor.jpa.sla.SLACalculationInsertUpdateJPAExecutor

All Implemented Interfaces:

JPAExecutor<String>

public class SLACalculationInsertUpdateJPAExecutor
extends Object
implements JPAExecutor<String>

Persist the SLA beans to tables SLA_CALCULATOR and SLA_SUMMARY.

Constructor Summary

SLACalculationInsertUpdateJPAExecutor()

SLACalculationInsertUpdateJPAExecutor(Collection<JsonBean> insertList, Collection<JsonBean> updateList)

Method Summary

String	execute(javax.persistence.EntityManager em) Method that encapsulates JPA access operations.
String	getName() Return the name of the JPA executor.
void	setInsertList(Collection<JsonBean> insertList) Sets the list of beans to insert
void	setUpdateList(Collection<JsonBean> updateList) Sets the list of beans to update

Methods inherited from class java.lang.Object

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

Constructor Detail

SLACalculationInsertUpdateJPAExecutor

public SLACalculationInsertUpdateJPAExecutor(Collection<JsonBean> insertList,
                                             Collection<JsonBean> updateList)

SLACalculationInsertUpdateJPAExecutor

public SLACalculationInsertUpdateJPAExecutor()

Method Detail

setInsertList

public void setInsertList(Collection<JsonBean> insertList)

Sets the list of beans to insert

Parameters:

insert -

setUpdateList

public void setUpdateList(Collection<JsonBean> updateList)

Sets the list of beans to update

Parameters:

update -

getName

public String getName()

Description copied from interface: JPAExecutor

Return the name of the JPA executor. Used for logging and instrumentation.

Specified by:

getName in interface JPAExecutor<String>

Returns:

the name of the JPA executor.

execute

public String execute(javax.persistence.EntityManager em)
               throws JPAExecutorException

Description copied from interface: JPAExecutor

Method that encapsulates JPA access operations.

Implementations should not close the received EntityManager.

Implementations should commit any transaction before ending, else the transaction will be rolled back.

Specified by:

execute in interface JPAExecutor<String>

Parameters:

em - an active EntityManager

Returns:

a return value if any.

Throws:

JPAExecutorException - thrown if a jpa executor failed