org.apache.flink.api.connector.source

Interface SourceReaderContext

All Known Implementing Classes:

TestingReaderContext

@Public
public interface SourceReaderContext

The interface that exposes some context from runtime to the SourceReader.

Method Summary

Modifier and Type	Method and Description
default int	currentParallelism() Get the current parallelism of this Source.
Configuration	getConfiguration() Gets the configuration with which Flink was started.
int	getIndexOfSubtask()
String	getLocalHostName() Gets the hostname of the machine where this reader is executed.
UserCodeClassLoader	getUserCodeClassLoader() Gets the UserCodeClassLoader to load classes that are not in system's classpath, but are part of the jar file of a user job.
SourceReaderMetricGroup	metricGroup()
void	sendSourceEventToCoordinator(SourceEvent sourceEvent) Send a source event to the source coordinator.
void	sendSplitRequest() Sends a split request to the source's SplitEnumerator.

Method Detail

metricGroup

SourceReaderMetricGroup metricGroup()

Returns:

The metric group this source belongs to.

getConfiguration

Configuration getConfiguration()

Gets the configuration with which Flink was started.

getLocalHostName

String getLocalHostName()

Gets the hostname of the machine where this reader is executed. This can be used to request splits local to the machine, if needed.

getIndexOfSubtask

int getIndexOfSubtask()

Returns:

The index of this subtask.

sendSplitRequest

void sendSplitRequest()

Sends a split request to the source's SplitEnumerator. This will result in a call to the SplitEnumerator.handleSplitRequest(int, String) method, with this reader's parallel subtask id and the hostname where this reader runs.

sendSourceEventToCoordinator

void sendSourceEventToCoordinator(SourceEvent sourceEvent)

Send a source event to the source coordinator.

Parameters:

sourceEvent - the source event to coordinator.

getUserCodeClassLoader

UserCodeClassLoader getUserCodeClassLoader()

Gets the UserCodeClassLoader to load classes that are not in system's classpath, but are part of the jar file of a user job.

See Also:

UserCodeClassLoader

currentParallelism

default int currentParallelism()

Get the current parallelism of this Source.

Returns:

the parallelism of the Source.