public interface AsyncCollector<OUT>
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 with
void collect(Throwable throwable)
throwable- to complete the async collector with
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.