org.apache.paimon.flink.source

Class NoOpEnumerator<SplitT extends org.apache.flink.api.connector.source.SourceSplit>

java.lang.Object

org.apache.paimon.flink.source.NoOpEnumerator<SplitT>

All Implemented Interfaces:

AutoCloseable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.api.connector.source.SplitEnumerator<SplitT,NoOpEnumState>

public class NoOpEnumerator<SplitT extends org.apache.flink.api.connector.source.SourceSplit>
extends Object
implements org.apache.flink.api.connector.source.SplitEnumerator<SplitT,NoOpEnumState>

A SplitEnumerator that provides no functionality. It is basically used for sources that does not require a coordinator.

Constructor Summary

Constructors

Constructor and Description
NoOpEnumerator()

Method Summary

Modifier and Type	Method and Description
void	addReader(int subtaskId)
void	addSplitsBack(List<SplitT> splits, int subtaskId)
void	close()
void	handleSplitRequest(int subtaskId, String requesterHostname)
NoOpEnumState	snapshotState(long checkpointId)
void	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.connector.source.SplitEnumerator

handleSourceEvent, notifyCheckpointComplete

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

notifyCheckpointAborted

Constructor Detail

NoOpEnumerator

public NoOpEnumerator()

Method Detail

start

public void start()

Specified by:

start in interface org.apache.flink.api.connector.source.SplitEnumerator<SplitT extends org.apache.flink.api.connector.source.SourceSplit,NoOpEnumState>

handleSplitRequest

public void handleSplitRequest(int subtaskId,
                               @Nullable
                               String requesterHostname)

Specified by:

handleSplitRequest in interface org.apache.flink.api.connector.source.SplitEnumerator<SplitT extends org.apache.flink.api.connector.source.SourceSplit,NoOpEnumState>

addSplitsBack

public void addSplitsBack(List<SplitT> splits,
                          int subtaskId)

Specified by:

addSplitsBack in interface org.apache.flink.api.connector.source.SplitEnumerator<SplitT extends org.apache.flink.api.connector.source.SourceSplit,NoOpEnumState>

addReader

public void addReader(int subtaskId)

Specified by:

addReader in interface org.apache.flink.api.connector.source.SplitEnumerator<SplitT extends org.apache.flink.api.connector.source.SourceSplit,NoOpEnumState>

snapshotState

public NoOpEnumState snapshotState(long checkpointId)
                            throws Exception

Specified by:

snapshotState in interface org.apache.flink.api.connector.source.SplitEnumerator<SplitT extends org.apache.flink.api.connector.source.SourceSplit,NoOpEnumState>

Throws:

Exception

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.flink.api.connector.source.SplitEnumerator<SplitT extends org.apache.flink.api.connector.source.SourceSplit,NoOpEnumState>

Throws:

IOException