Streaming C++ API
|
A callback interface that can be implemented by an object that is associated with a StreamBaseClient and which gets used in the course of dequeuing tuples. More...
#include <DequeueResult.hpp>
Public Member Functions | |
virtual DequeueResult | processResult (const DequeueResult &results) |
Take a DequeueResult and modify it. More... | |
Static Public Attributes | |
static const DequeueResult | SUPPRESSED |
SUPPRESSED is a flag used to signify that the results from processResult should be suppressed. More... | |
A callback interface that can be implemented by an object that is associated with a StreamBaseClient and which gets used in the course of dequeuing tuples.
|
inlinevirtual |
Take a DequeueResult and modify it.
Returns the same object if there are no changes. Returns SUPPRESSED if results should be suppressed. May return a different DequeueResult object.
|
static |
SUPPRESSED is a flag used to signify that the results from processResult should be suppressed.