org.apache.hama.bsp
Interface Queue<T>

Type Parameters:
T -

public interface Queue<T>

Job Queue interface.


Method Summary
 void addJob(T job)
          Add a job to a queue.
 java.lang.String getName()
          The queue name.
 java.util.Collection<T> jobs()
          Return all data stored in this queue.
 T removeJob()
          Get a job
 void removeJob(T job)
          Remove a job from the queue.
 

Method Detail

getName

java.lang.String getName()
The queue name.

Returns:
the name of current queue.

addJob

void addJob(T job)
Add a job to a queue.

Parameters:
job - to be added to the queue.

removeJob

void removeJob(T job)
Remove a job from the queue.

Parameters:
job - to be removed from the queue.

removeJob

T removeJob()
Get a job

Returns:
job that is removed from the queue.

jobs

java.util.Collection<T> jobs()
Return all data stored in this queue.

Returns:
Collection of jobs.


Copyright © 2008-2011 The Apache Software Foundation. All Rights Reserved.