Package org.apache.flink.connector.testframe.testsuites

Class SourceTestSuiteBase.CollectIteratorBuilder<T>

java.lang.Object

org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.CollectIteratorBuilder<T>

Enclosing class:

SourceTestSuiteBase<T>

protected static class SourceTestSuiteBase.CollectIteratorBuilder<T>
extends Object

Builder class for constructing CollectResultIterator of collect sink.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CollectIteratorBuilder(org.apache.flink.streaming.api.operators.collect.CollectSinkOperator<T> operator, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, String accumulatorName, org.apache.flink.streaming.api.environment.CheckpointConfig checkpointConfig)

Method Summary

Modifier and Type	Method	Description
protected org.apache.flink.streaming.api.operators.collect.CollectResultIterator<T>	build(org.apache.flink.core.execution.JobClient jobClient)

Methods inherited from class java.lang.Object

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

Constructor Detail

CollectIteratorBuilder

protected CollectIteratorBuilder(org.apache.flink.streaming.api.operators.collect.CollectSinkOperator<T> operator,
                                 org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer,
                                 String accumulatorName,
                                 org.apache.flink.streaming.api.environment.CheckpointConfig checkpointConfig)

Method Detail

build

protected org.apache.flink.streaming.api.operators.collect.CollectResultIterator<T> build(org.apache.flink.core.execution.JobClient jobClient)