Package org.apache.flink.connector.testutils.source.reader

Class TestingReaderContext

java.lang.Object

org.apache.flink.connector.testutils.source.reader.TestingReaderContext

All Implemented Interfaces:

org.apache.flink.api.connector.source.SourceReaderContext

public class TestingReaderContext
extends Object
implements org.apache.flink.api.connector.source.SourceReaderContext

A testing implementation of the SourceReaderContext.

Constructor Summary

Constructors

Constructor	Description
TestingReaderContext()
TestingReaderContext(org.apache.flink.configuration.Configuration config, org.apache.flink.metrics.groups.SourceReaderMetricGroup metricGroup)

Method Summary

Modifier and Type	Method	Description
void	clearSentEvents()
int	currentParallelism()
org.apache.flink.configuration.Configuration	getConfiguration()
int	getIndexOfSubtask()
String	getLocalHostName()
int	getNumSplitRequests()
List<org.apache.flink.api.connector.source.SourceEvent>	getSentEvents()
org.apache.flink.util.UserCodeClassLoader	getUserCodeClassLoader()
org.apache.flink.metrics.groups.SourceReaderMetricGroup	metricGroup()
void	sendSourceEventToCoordinator(org.apache.flink.api.connector.source.SourceEvent sourceEvent)
void	sendSplitRequest()

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

emitWatermark

Constructor Detail

TestingReaderContext

public TestingReaderContext()

TestingReaderContext

public TestingReaderContext(org.apache.flink.configuration.Configuration config,
                            org.apache.flink.metrics.groups.SourceReaderMetricGroup metricGroup)

Method Detail

metricGroup

public org.apache.flink.metrics.groups.SourceReaderMetricGroup metricGroup()

Specified by:

metricGroup in interface org.apache.flink.api.connector.source.SourceReaderContext

getConfiguration

public org.apache.flink.configuration.Configuration getConfiguration()

Specified by:

getConfiguration in interface org.apache.flink.api.connector.source.SourceReaderContext

getLocalHostName

public String getLocalHostName()

Specified by:

getLocalHostName in interface org.apache.flink.api.connector.source.SourceReaderContext

getIndexOfSubtask

public int getIndexOfSubtask()

Specified by:

getIndexOfSubtask in interface org.apache.flink.api.connector.source.SourceReaderContext

sendSplitRequest

public void sendSplitRequest()

Specified by:

sendSplitRequest in interface org.apache.flink.api.connector.source.SourceReaderContext

sendSourceEventToCoordinator

public void sendSourceEventToCoordinator(org.apache.flink.api.connector.source.SourceEvent sourceEvent)

Specified by:

sendSourceEventToCoordinator in interface org.apache.flink.api.connector.source.SourceReaderContext

getUserCodeClassLoader

public org.apache.flink.util.UserCodeClassLoader getUserCodeClassLoader()

Specified by:

getUserCodeClassLoader in interface org.apache.flink.api.connector.source.SourceReaderContext

currentParallelism

public int currentParallelism()

Specified by:

currentParallelism in interface org.apache.flink.api.connector.source.SourceReaderContext

getNumSplitRequests

public int getNumSplitRequests()

getSentEvents

public List<org.apache.flink.api.connector.source.SourceEvent> getSentEvents()

clearSentEvents

public void clearSentEvents()