org.apache.flink.streaming.api.operators.collect

类 CollectResultFetcher<T>

java.lang.Object

org.apache.flink.streaming.api.operators.collect.CollectResultFetcher<T>

public class CollectResultFetcher<T>
extends Object

A fetcher which fetches query results from sink and provides exactly-once semantics.

构造器概要

构造器

构造器和说明
CollectResultFetcher(AbstractCollectResultBuffer<T> buffer, CompletableFuture<org.apache.flink.runtime.jobgraph.OperatorID> operatorIdFuture, String accumulatorName, long resultFetchTimeout)

方法概要

限定符和类型	方法和说明
void	close()
T	next()
void	setJobClient(org.apache.flink.core.execution.JobClient jobClient)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

CollectResultFetcher

public CollectResultFetcher(AbstractCollectResultBuffer<T> buffer,
                            CompletableFuture<org.apache.flink.runtime.jobgraph.OperatorID> operatorIdFuture,
                            String accumulatorName,
                            long resultFetchTimeout)

方法详细资料

setJobClient

public void setJobClient(org.apache.flink.core.execution.JobClient jobClient)

next

public T next()
       throws IOException

抛出:

IOException

close

public void close()