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

java.lang.Object
  extended by 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


Copyright © 2013 Apache Software Foundation. All Rights Reserved.