Interface DequeueResult.Interceptor

  • Enclosing class:
    DequeueResult

    public static interface DequeueResult.Interceptor
    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.
    Since:
    5.1
    • Method Detail

      • processResult

        DequeueResult processResult​(DequeueResult results)
        Take a DequeueResult and modify it. Returns the same object if there are no changes. Returns null if the dequeue results should be suppressed. May return a different DequeueResult object.
        Parameters:
        results - The in bound results
        Returns:
        possibly modified dequeue result
        Since:
        5.1