@InterfaceAudience.Private public class ParallelSeekHandler extends EventHandler
Modifier and Type | Field and Description |
---|---|
private Throwable |
err |
private Cell |
keyValue |
private CountDownLatch |
latch |
private static org.slf4j.Logger |
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, getPriority, getSeqid, handleException, prepare, run, toString
private static final org.slf4j.Logger LOG
private KeyValueScanner scanner
private long readPoint
private CountDownLatch latch
public ParallelSeekHandler(KeyValueScanner scanner, Cell keyValue, long readPoint, CountDownLatch latch)
public void process()
EventHandler
process
in class EventHandler
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.