Package com.here.platform.data.client.flink.impl

Class RetractDummySource

java.lang.Object

com.here.platform.data.client.flink.impl.RetractDummySource

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.source.Source<org.apache.flink.types.Row,SingleSplitSourceUtils.Split,Collection<SingleSplitSourceUtils.Split>>, org.apache.flink.api.connector.source.SourceReaderFactory<org.apache.flink.types.Row,SingleSplitSourceUtils.Split>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.types.Row>

public class RetractDummySource
extends Object
implements org.apache.flink.api.connector.source.Source<org.apache.flink.types.Row,SingleSplitSourceUtils.Split,Collection<SingleSplitSourceUtils.Split>>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.types.Row>

Emits dummy messages with the main stream is finished we need it to let all the downstream logic to complete properly

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
RetractDummySource(Schema schema)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.connector.source.SplitEnumerator<SingleSplitSourceUtils.Split,Collection<SingleSplitSourceUtils.Split>>	createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SingleSplitSourceUtils.Split> enumContext)
org.apache.flink.api.connector.source.SourceReader<org.apache.flink.types.Row,SingleSplitSourceUtils.Split>	createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)
org.apache.flink.api.connector.source.Boundedness	getBoundedness()
org.apache.flink.core.io.SimpleVersionedSerializer<Collection<SingleSplitSourceUtils.Split>>	getEnumeratorCheckpointSerializer()
org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row>	getProducedType()
org.apache.flink.core.io.SimpleVersionedSerializer<SingleSplitSourceUtils.Split>	getSplitSerializer()
org.apache.flink.api.connector.source.SplitEnumerator<SingleSplitSourceUtils.Split,Collection<SingleSplitSourceUtils.Split>>	restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SingleSplitSourceUtils.Split> enumContext, Collection<SingleSplitSourceUtils.Split> checkpoint)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.api.connector.source.Source

declareWatermarks

Constructor Details

RetractDummySource

public RetractDummySource(Schema schema)

Method Details

createEnumerator

public org.apache.flink.api.connector.source.SplitEnumerator<SingleSplitSourceUtils.Split,Collection<SingleSplitSourceUtils.Split>> createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SingleSplitSourceUtils.Split> enumContext)

Specified by:

createEnumerator in interface org.apache.flink.api.connector.source.Source<org.apache.flink.types.Row,SingleSplitSourceUtils.Split,Collection<SingleSplitSourceUtils.Split>>

createReader

public org.apache.flink.api.connector.source.SourceReader<org.apache.flink.types.Row,SingleSplitSourceUtils.Split> createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)

Specified by:

createReader in interface org.apache.flink.api.connector.source.SourceReaderFactory<org.apache.flink.types.Row,SingleSplitSourceUtils.Split>

getBoundedness

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

Specified by:

getBoundedness in interface org.apache.flink.api.connector.source.Source<org.apache.flink.types.Row,SingleSplitSourceUtils.Split,Collection<SingleSplitSourceUtils.Split>>

getEnumeratorCheckpointSerializer

public org.apache.flink.core.io.SimpleVersionedSerializer<Collection<SingleSplitSourceUtils.Split>> getEnumeratorCheckpointSerializer()

Specified by:

getEnumeratorCheckpointSerializer in interface org.apache.flink.api.connector.source.Source<org.apache.flink.types.Row,SingleSplitSourceUtils.Split,Collection<SingleSplitSourceUtils.Split>>

getProducedType

public org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> getProducedType()

Specified by:

getProducedType in interface org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.types.Row>

getSplitSerializer

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

Specified by:

getSplitSerializer in interface org.apache.flink.api.connector.source.Source<org.apache.flink.types.Row,SingleSplitSourceUtils.Split,Collection<SingleSplitSourceUtils.Split>>

restoreEnumerator

public org.apache.flink.api.connector.source.SplitEnumerator<SingleSplitSourceUtils.Split,Collection<SingleSplitSourceUtils.Split>> restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SingleSplitSourceUtils.Split> enumContext,
 Collection<SingleSplitSourceUtils.Split> checkpoint)

Specified by:

restoreEnumerator in interface org.apache.flink.api.connector.source.Source<org.apache.flink.types.Row,SingleSplitSourceUtils.Split,Collection<SingleSplitSourceUtils.Split>>