Class TestSplit

  • All Implemented Interfaces:
    org.apache.flink.api.connector.source.SourceSplit

    @PublicEvolving
    public class TestSplit
    extends Object
    implements org.apache.flink.api.connector.source.SourceSplit
    A simple test split implementation that can be reused across test sources. This provides a minimal split that is sufficient for most testing scenarios.
    • Field Detail

      • INSTANCE

        public static final TestSplit INSTANCE
        Singleton instance for reuse across all test sources.
      • SERIALIZER

        public static final org.apache.flink.core.io.SimpleVersionedSerializer<TestSplit> SERIALIZER
        Serializer for TestSplit instances.
    • Method Detail

      • splitId

        public String splitId()
        Specified by:
        splitId in interface org.apache.flink.api.connector.source.SourceSplit