@InterfaceAudience.Private public class ParallelSeekHandler extends EventHandler
EventHandler.EventHandlerListener| Modifier and Type | Field and Description |
|---|---|
private Throwable |
err |
private Cell |
keyValue |
private CountDownLatch |
latch |
private static org.apache.commons.logging.Log |
LOG |
private long |
readPoint |
private KeyValueScanner |
scanner |
eventType, seqids, server, waitingTimeForEvents| Constructor and Description |
|---|
ParallelSeekHandler(KeyValueScanner scanner,
Cell keyValue,
long readPoint,
CountDownLatch latch) |
| Modifier and Type | Method and Description |
|---|---|
Throwable |
getErr() |
void |
process()
This method is the main processing loop to be implemented by the various
subclasses.
|
void |
setErr(Throwable err) |
compareTo, getEventType, getInformativeName, getListener, getPriority, getSeqid, handleException, prepare, run, setListener, toStringprivate static final org.apache.commons.logging.Log LOG
private KeyValueScanner scanner
private Cell keyValue
private long readPoint
private CountDownLatch latch
private Throwable err
public ParallelSeekHandler(KeyValueScanner scanner, Cell keyValue, long readPoint, CountDownLatch latch)
public void process()
EventHandlerprocess in class EventHandlerpublic Throwable getErr()
public void setErr(Throwable err)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.