Uses of Class
org.apache.flink.test.util.source.TestSplit

Uses of TestSplit in org.apache.flink.test.util.source

Fields in org.apache.flink.test.util.source declared as TestSplit

Modifier and Type	Field	Description
static TestSplit	TestSplit.INSTANCE	Singleton instance for reuse across all test sources.

Fields in org.apache.flink.test.util.source with type parameters of type TestSplit

Modifier and Type	Field	Description
protected org.apache.flink.api.connector.source.SplitEnumeratorContext<TestSplit>	TestSplitEnumerator.context
static org.apache.flink.core.io.SimpleVersionedSerializer<TestSplit>	TestSplit.SERIALIZER	Serializer for TestSplit instances.

Methods in org.apache.flink.test.util.source that return types with arguments of type TestSplit

Modifier and Type	Method	Description
org.apache.flink.api.connector.source.SplitEnumerator<TestSplit,EnumChkptState>	AbstractTestSourceBase.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<TestSplit> enumContext)	Creates a new split enumerator for fresh starts.
org.apache.flink.api.connector.source.SourceReader<T,TestSplit>	AbstractTestSourceBase.createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)	Creates a source reader.
org.apache.flink.core.io.SimpleVersionedSerializer<TestSplit>	AbstractTestSourceBase.getSplitSerializer()
org.apache.flink.api.connector.source.SplitEnumerator<TestSplit,EnumChkptState>	AbstractTestSourceBase.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<TestSplit> enumContext, EnumChkptState checkpoint)	Restores a split enumerator from a checkpoint.
List<TestSplit>	TestSourceReader.snapshotState(long checkpointId)

Method parameters in org.apache.flink.test.util.source with type arguments of type TestSplit

Modifier and Type	Method	Description
void	TestSourceReader.addSplits(List<TestSplit> splits)
void	TestSplitEnumerator.addSplitsBack(List<TestSplit> splits, int subtaskId)
org.apache.flink.api.connector.source.SplitEnumerator<TestSplit,EnumChkptState>	AbstractTestSourceBase.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<TestSplit> enumContext)	Creates a new split enumerator for fresh starts.
org.apache.flink.api.connector.source.SplitEnumerator<TestSplit,EnumChkptState>	AbstractTestSourceBase.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<TestSplit> enumContext, EnumChkptState checkpoint)	Restores a split enumerator from a checkpoint.

Constructor parameters in org.apache.flink.test.util.source with type arguments of type TestSplit

Constructor	Description
SingleSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<TestSplit> context)
TestSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<TestSplit> context, EnumChkptState checkpointState)