public interface Dequeuer
| Modifier and Type | Field and Description |
|---|---|
static long |
DEFAULT_TIMEOUT
The default timeout value: 3
|
static TimeUnit |
DEFAULT_TIMEOUT_UNIT
The default timeout units:
TimeUnit.SECONDS |
| Modifier and Type | Method and Description |
|---|---|
List<Tuple> |
dequeue(int numTuples)
Try to dequeue tuples with the
Dequeuer.DEFAULT_TIMEOUT and Dequeuer.DEFAULT_TIMEOUT_UNIT
if numTuples == 0 will return immediately
if numTuples < 0 will wait the maximum timeout before returning
|
List<Tuple> |
dequeue(int numTuples,
long timeout,
TimeUnit timeUnit)
Try to dequeue tuples within a provided timeout.
|
void |
drain()
Drain any tuples that are currently in flight in the server.
|
Schema |
getSchema()
|
StreamProperties |
getStreamProperties()
Get the
StreamProperties for the associated stream. |
static final long DEFAULT_TIMEOUT
static final TimeUnit DEFAULT_TIMEOUT_UNIT
TimeUnit.SECONDSStreamProperties getStreamProperties()
StreamProperties for the associated stream.Schema getSchema()
List<Tuple> dequeue(int numTuples) throws StreamBaseException
Dequeuer.DEFAULT_TIMEOUT and Dequeuer.DEFAULT_TIMEOUT_UNIT
numTuples - the number of tuples to dequeueStreamBaseException - Dequeue failedList<Tuple> dequeue(int numTuples, long timeout, TimeUnit timeUnit) throws StreamBaseException
numTuples - the number of tuples to dequeuetimeout - the maximum time to waittimeUnit - the time unit of timeout argumentStreamBaseException - Dequeue failedvoid drain()
throws StreamBaseException
StreamBaseException - Drain failedCopyright © 2015–2018 Cloud Software Group, Inc.. All rights reserved.