Class TestingSourceSettings


  • public class TestingSourceSettings
    extends Object
    Settings for configuring the source under testing.
    • Method Detail

      • 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.