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