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 and Description
protected	CollectIteratorBuilder(CollectSinkOperator<T> operator, TypeSerializer<T> serializer, String accumulatorName, CheckpointConfig checkpointConfig)

Method Summary

Modifier and Type	Method and Description
protected CollectResultIterator<T>	build(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(CollectSinkOperator<T> operator,
                                 TypeSerializer<T> serializer,
                                 String accumulatorName,
                                 CheckpointConfig checkpointConfig)

Method Detail

build

protected CollectResultIterator<T> build(JobClient jobClient)