Package org.apache.flink.connector.testframe.external.source

Class TestingSourceSettings.Builder

java.lang.Object

org.apache.flink.connector.testframe.external.source.TestingSourceSettings.Builder

Enclosing class:

TestingSourceSettings

public static class TestingSourceSettings.Builder
extends Object

Builder class for TestingSourceSettings.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
TestingSourceSettings	build()
TestingSourceSettings.Builder	setBoundedness(org.apache.flink.api.connector.source.Boundedness boundedness)
TestingSourceSettings.Builder	setCheckpointingMode(org.apache.flink.streaming.api.CheckpointingMode checkpointingMode)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

setBoundedness

public TestingSourceSettings.Builder setBoundedness(org.apache.flink.api.connector.source.Boundedness boundedness)

setCheckpointingMode

public TestingSourceSettings.Builder setCheckpointingMode(org.apache.flink.streaming.api.CheckpointingMode checkpointingMode)

build

public TestingSourceSettings build()