This project has retired. For details please refer to its
Attic page .
BulkJPAExecutor (Apache Oozie Core 3.3.2 API)
org.apache.oozie.executor.jpa
Class BulkJPAExecutor
java.lang.Object
org.apache.oozie.executor.jpa.BulkJPAExecutor
All Implemented Interfaces: JPAExecutor <BulkResponseInfo >
public class BulkJPAExecutor extends Object implements JPAExecutor <BulkResponseInfo >
The query executor class for bulk monitoring queries i.e. debugging bundle ->
coord actions directly
Methods inherited from class java.lang.Object
clone , equals , finalize , getClass , hashCode , notify , notifyAll , toString , wait , wait , wait
BulkJPAExecutor
public BulkJPAExecutor (Map <String ,List <String >> bulkFilter,
int start,
int len)
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 <BulkResponseInfo >
Returns: the name of the JPA executor.
execute
public BulkResponseInfo 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 <BulkResponseInfo >
Parameters: em
- an active EntityManager
Returns: a return value if any.
Throws:
JPAExecutorException
- thrown if a jpa executor failed
nullToEmpty
public static List <String > nullToEmpty (List <String > input)
Copyright © 2013 Apache Software Foundation . All Rights Reserved.