org.apache.oozie.executor.jpa
Class CoordJobsToBeMaterializedJPAExecutor
java.lang.Object
org.apache.oozie.executor.jpa.CoordJobsToBeMaterializedJPAExecutor
- All Implemented Interfaces:
- JPAExecutor<List<CoordinatorJobBean>>
public class CoordJobsToBeMaterializedJPAExecutor
- extends Object
- implements JPAExecutor<List<CoordinatorJobBean>>
JPA command to get coordinator jobs which are qualify for Materialization.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CoordJobsToBeMaterializedJPAExecutor
public CoordJobsToBeMaterializedJPAExecutor(Date date,
int limit)
- Parameters:
date
- limit
-
execute
public List<CoordinatorJobBean> 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<List<CoordinatorJobBean>>
- Parameters:
em
- an active EntityManager
- Returns:
- a return value if any.
- Throws:
JPAExecutorException
- thrown if a jpa executor failed
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<List<CoordinatorJobBean>>
- Returns:
- the name of the JPA executor.
getDateInput
public Date getDateInput()
- Returns:
- the dateInput
setDateInput
public void setDateInput(Date dateInput)
- Parameters:
dateInput
- the dateInput to set
getLimit
public int getLimit()
- Returns:
- the limit
setLimit
public void setLimit(int limit)
- Parameters:
limit
- the limit to set
Copyright © 2013 Apache Software Foundation. All Rights Reserved.