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

Constructor Summary

BulkJPAExecutor(Map<String,List<String>> bulkFilter, int start, int len)

Method Summary

BulkResponseInfo	execute(javax.persistence.EntityManager em) Method that encapsulates JPA access operations.
String	getName() Return the name of the JPA executor.
static List<String>	nullToEmpty(List<String> input)

Methods inherited from class java.lang.Object

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

Constructor Detail

BulkJPAExecutor

public BulkJPAExecutor(Map<String,List<String>> bulkFilter,
                       int start,
                       int len)

Method Detail

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)