org.apache.oozie.event

Interface EventQueue

All Known Implementing Classes:

MemoryEventQueue

public interface EventQueue

Interface to define the queue operations for the events system

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	EventQueue.EventQueueElement

Method Summary

Methods

Modifier and Type	Method and Description
void	add(Event e) Add event to queue
void	clear() Clear the events queue
int	getBatchSize() Get the batch size used during polling events
void	init(org.apache.hadoop.conf.Configuration conf) Initialize the event queue
boolean	isEmpty() Find out if queue is empty
Event	peek() Read topmost event from queue but do not pop from it
Event	poll() Fetch single event from queue
List<Event>	pollBatch() Fetch events from queue in batch
int	size() Get current queue size

Method Detail

init

void init(org.apache.hadoop.conf.Configuration conf)

Initialize the event queue

Parameters:

conf -

add

void add(Event e)

Add event to queue

Parameters:

event -

pollBatch

List<Event> pollBatch()

Fetch events from queue in batch

Returns:

events set

poll

Event poll()

Fetch single event from queue

Returns:

event

isEmpty

boolean isEmpty()

Find out if queue is empty

Returns:

boolean

size

int size()

Get current queue size

Returns:

size

peek

Event peek()

Read topmost event from queue but do not pop from it

Returns:

event

getBatchSize

int getBatchSize()

Get the batch size used during polling events

Returns:

batchSize

clear

void clear()

Clear the events queue