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

Class TestingSourceSettings

java.lang.Object

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

public class TestingSourceSettings
extends Object

Settings for configuring the source under testing.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestingSourceSettings.Builder	Builder class for TestingSourceSettings.

Method Summary

Modifier and Type	Method	Description
static TestingSourceSettings.Builder	builder()
org.apache.flink.api.connector.source.Boundedness	getBoundedness()	Boundedness of the source.
org.apache.flink.streaming.api.CheckpointingMode	getCheckpointingMode()	Checkpointing mode required for the source.

Methods inherited from class java.lang.Object

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

Method Detail

builder

public static TestingSourceSettings.Builder builder()

getBoundedness

public org.apache.flink.api.connector.source.Boundedness getBoundedness()

Boundedness of the source.

getCheckpointingMode

public org.apache.flink.streaming.api.CheckpointingMode getCheckpointingMode()

Checkpointing mode required for the source.