InputDatum<T> dequeue(long timeout, TimeUnit timeoutUnit) throws IOException, InterruptedException
timeout- Maximum time for trying to have a non-empty dequeue result. Depending on the implementation, actual time spent for dequeue could be longer than the time specified here.
timeoutUnit- Unit for the timeout.
InputDatumwhich represents the input being read from the queue.
IOException- If fails to dequeue.
InterruptedException- If dequeue is interrupted.
Copyright © 2018 Cask Data, Inc.. All rights reserved.