public class TriggerEventQueue extends ZkDistributedQueue
Modifier and Type | Field and Description |
---|---|
static String |
DEQUEUE_TIME |
static String |
ENQUEUE_TIME |
Constructor and Description |
---|
TriggerEventQueue(SolrZkClient zookeeper,
String triggerName,
Overseer.Stats stats) |
Modifier and Type | Method and Description |
---|---|
boolean |
offerEvent(TriggerEvent event) |
TriggerEvent |
peekEvent() |
TriggerEvent |
pollEvent() |
getStats, offer, peek, peek, peek, peekElements, poll, remove, take
public static final String ENQUEUE_TIME
public static final String DEQUEUE_TIME
public TriggerEventQueue(SolrZkClient zookeeper, String triggerName, Overseer.Stats stats)
public boolean offerEvent(TriggerEvent event)
public TriggerEvent peekEvent()
public TriggerEvent pollEvent()
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.