Package org.apache.flink.test.util.source

Class SingleSplitEnumerator

java.lang.Object

org.apache.flink.test.util.source.TestSplitEnumerator<Void>

org.apache.flink.test.util.source.SingleSplitEnumerator

All Implemented Interfaces:

AutoCloseable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.api.connector.source.SplitEnumerator<TestSplit,Void>

@PublicEvolving
public class SingleSplitEnumerator
extends TestSplitEnumerator<Void>

A split enumerator where the first reader gets one split, others get nothing.

Useful for tests that need minimal data processing on a single subtask.

Field Summary

Fields inherited from class org.apache.flink.test.util.source.TestSplitEnumerator

checkpointState, context

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	addReader(int subtaskId)

Methods inherited from class org.apache.flink.test.util.source.TestSplitEnumerator

addSplitsBack, close, handleSplitRequest, snapshotState, start

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.common.state.CheckpointListener

notifyCheckpointAborted

Methods inherited from interface org.apache.flink.api.connector.source.SplitEnumerator

handleSourceEvent, notifyCheckpointComplete

Constructor Detail

SingleSplitEnumerator

public SingleSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<TestSplit> context)

Method Detail

addReader

public void addReader(int subtaskId)

Specified by:

addReader in interface org.apache.flink.api.connector.source.SplitEnumerator<TestSplit,Void>

Overrides:

addReader in class TestSplitEnumerator<Void>