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 classTestingSourceSettings.BuilderBuilder class forTestingSourceSettings.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static TestingSourceSettings.Builderbuilder()org.apache.flink.api.connector.source.BoundednessgetBoundedness()Boundedness of the source.org.apache.flink.streaming.api.CheckpointingModegetCheckpointingMode()Deprecated.
-
-
-
Method Detail
-
builder
public static TestingSourceSettings.Builder builder()
-
getBoundedness
public org.apache.flink.api.connector.source.Boundedness getBoundedness()
Boundedness of the source.
-
getCheckpointingMode
@Deprecated public org.apache.flink.streaming.api.CheckpointingMode getCheckpointingMode()
Deprecated.Checkpointing mode required for the source. 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.
-
-