public interface AsyncCollector<OUT>
Modifier and Type | Method and Description |
---|---|
void |
collect(scala.collection.Iterable<OUT> result)
Complete the async collector with a set of result elements.
|
void |
collect(Throwable throwable)
Complete this async collector with an error.
|
void collect(scala.collection.Iterable<OUT> result)
Note that it should be called for exactly one time in the user code. Calling this function for multiple times will cause data lose.
Put all results in a Iterable
and then issue AsyncCollector.collect(Iterable).
result
- to complete the async collector withvoid collect(Throwable throwable)
throwable
- to complete the async collector withCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.