Package org.apache.flink.connector.testframe.source

Class FromElementsSource<OUT>

java.lang.Object

org.apache.flink.connector.testframe.source.FromElementsSource<OUT>

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.source.Source<OUT,FromElementsSplit,NoOpEnumState>, org.apache.flink.api.connector.source.SourceReaderFactory<OUT,FromElementsSplit>

public class FromElementsSource<OUT>
extends Object
implements org.apache.flink.api.connector.source.Source<OUT,FromElementsSplit,NoOpEnumState>

A Source implementation that reads data from a list or from a FromElementsSource.ElementsSupplier and stops reading at the fixed position. The source will wait until the checkpoint or savepoint triggered, the source is useful for connector tests.

Note: This parallelism of source must be 1.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	FromElementsSource.ElementsSupplier<OUT>	A supplier of elements that allows to get those from any offset at any time.

Constructor Summary

Constructors

Constructor	Description
FromElementsSource(List<OUT> elements)
FromElementsSource(org.apache.flink.api.connector.source.Boundedness boundedness, List<OUT> elements, Integer emittedElementsNum)
FromElementsSource(FromElementsSource.ElementsSupplier<OUT> elementsSupplier)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.connector.source.SplitEnumerator<FromElementsSplit,NoOpEnumState>	createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FromElementsSplit> enumContext)
org.apache.flink.api.connector.source.SourceReader<OUT,FromElementsSplit>	createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)
org.apache.flink.api.connector.source.Boundedness	getBoundedness()
org.apache.flink.core.io.SimpleVersionedSerializer<NoOpEnumState>	getEnumeratorCheckpointSerializer()
org.apache.flink.core.io.SimpleVersionedSerializer<FromElementsSplit>	getSplitSerializer()
org.apache.flink.api.connector.source.SplitEnumerator<FromElementsSplit,NoOpEnumState>	restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FromElementsSplit> enumContext, NoOpEnumState checkpoint)

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

declareWatermarks

Constructor Detail

FromElementsSource

public FromElementsSource(List<OUT> elements)

FromElementsSource

public FromElementsSource(FromElementsSource.ElementsSupplier<OUT> elementsSupplier)

FromElementsSource

public FromElementsSource(org.apache.flink.api.connector.source.Boundedness boundedness,
                          List<OUT> elements,
                          Integer emittedElementsNum)

Method Detail

getBoundedness

public org.apache.flink.api.connector.source.Boundedness getBoundedness()

Specified by:

getBoundedness in interface org.apache.flink.api.connector.source.Source<OUT,FromElementsSplit,NoOpEnumState>

createReader

public org.apache.flink.api.connector.source.SourceReader<OUT,FromElementsSplit> createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)
                                                                                             throws Exception

Specified by:

createReader in interface org.apache.flink.api.connector.source.SourceReaderFactory<OUT,FromElementsSplit>

Throws:

Exception

createEnumerator

public org.apache.flink.api.connector.source.SplitEnumerator<FromElementsSplit,NoOpEnumState> createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FromElementsSplit> enumContext)
                                                                                                              throws Exception

Specified by:

createEnumerator in interface org.apache.flink.api.connector.source.Source<OUT,FromElementsSplit,NoOpEnumState>

Throws:

Exception

restoreEnumerator

public org.apache.flink.api.connector.source.SplitEnumerator<FromElementsSplit,NoOpEnumState> restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FromElementsSplit> enumContext,
                                                                                                                      NoOpEnumState checkpoint)
                                                                                                               throws Exception

Specified by:

restoreEnumerator in interface org.apache.flink.api.connector.source.Source<OUT,FromElementsSplit,NoOpEnumState>

Throws:

Exception

getSplitSerializer

public org.apache.flink.core.io.SimpleVersionedSerializer<FromElementsSplit> getSplitSerializer()

Specified by:

getSplitSerializer in interface org.apache.flink.api.connector.source.Source<OUT,FromElementsSplit,NoOpEnumState>

getEnumeratorCheckpointSerializer

public org.apache.flink.core.io.SimpleVersionedSerializer<NoOpEnumState> getEnumeratorCheckpointSerializer()

Specified by:

getEnumeratorCheckpointSerializer in interface org.apache.flink.api.connector.source.Source<OUT,FromElementsSplit,NoOpEnumState>