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.core.execution.CheckpointingMode checkpointingMode)
TestingSourceSettings.Builder	setCheckpointingMode(org.apache.flink.streaming.api.CheckpointingMode checkpointingMode)	Deprecated.

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.core.execution.CheckpointingMode checkpointingMode)

setCheckpointingMode

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

Deprecated.

This method is required for downstream projects e.g. Flink connectors extending this test for the case when there should be supported Flink versions below 1.20. Could be removed together with dropping support for Flink 1.19.

build

public TestingSourceSettings build()