public class CollectResultFetcher<T> extends Object
Constructor and Description |
---|
CollectResultFetcher(AbstractCollectResultBuffer<T> buffer,
CompletableFuture<OperatorID> operatorIdFuture,
String accumulatorName) |
public CollectResultFetcher(AbstractCollectResultBuffer<T> buffer, CompletableFuture<OperatorID> operatorIdFuture, String accumulatorName)
public void setJobClient(JobClient jobClient)
public T next() throws IOException
IOException
public void close()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.