org.apache.flink.api.connector.source

Interface SourceReaderContext

All Known Implementing Classes:

TestingReaderContext

@PublicEvolving
public interface SourceReaderContext

The class that expose some context from runtime to the SourceReader.

Method Summary

Modifier and Type	Method and Description
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.
MetricGroup	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

MetricGroup 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.