org.apache.oozie.service

Class CallableQueueService.CallableWrapper<E>

java.lang.Object

java.util.concurrent.FutureTask<E>

org.apache.oozie.util.PriorityDelayQueue.QueueElement<E>

org.apache.oozie.service.CallableQueueService.CallableWrapper<E>

All Implemented Interfaces:

java.lang.Comparable<java.util.concurrent.Delayed>, java.lang.Runnable, java.util.concurrent.Callable<E>, java.util.concurrent.Delayed, java.util.concurrent.Future<E>, java.util.concurrent.RunnableFuture<E>

Enclosing class:

CallableQueueService

public class CallableQueueService.CallableWrapper<E>
extends PriorityDelayQueue.QueueElement<E>
implements java.lang.Runnable, java.util.concurrent.Callable<E>

Constructor Summary

Constructors

Constructor and Description
CallableQueueService.CallableWrapper(XCallable<E> callable, long delay)

Method Summary

Methods

Modifier and Type	Method and Description
void	addToUniqueCallables() Add the keys to the set
E	call()
boolean	filterDuplicates() Filter the duplicate callables from the list before queue this.
void	removeFromUniqueCallables() Remove the keys from the set
void	run()

Methods inherited from class org.apache.oozie.util.PriorityDelayQueue.QueueElement

compareTo, getDelay, getElement, getPriority, setDelay, toString

Methods inherited from class java.util.concurrent.FutureTask

cancel, done, get, get, isCancelled, isDone, runAndReset, set, setException

Methods inherited from class java.lang.Object

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

Constructor Detail

CallableQueueService.CallableWrapper

public CallableQueueService.CallableWrapper(XCallable<E> callable,
                                    long delay)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Specified by:

run in interface java.util.concurrent.RunnableFuture<E>

Overrides:

run in class java.util.concurrent.FutureTask<E>

filterDuplicates

public boolean filterDuplicates()

Filter the duplicate callables from the list before queue this.

If it is single callable, checking if key is in unique map or not.

If it is composite callable, remove duplicates callables from the composite.

Returns:

true if this callable should be queued

addToUniqueCallables

public void addToUniqueCallables()

Add the keys to the set

removeFromUniqueCallables

public void removeFromUniqueCallables()

Remove the keys from the set

call

public E call()
       throws java.lang.Exception

Specified by:

call in interface java.util.concurrent.Callable<E>

Throws:

java.lang.Exception