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

Class StreamLayerRowRichSource

java.lang.Object

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

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.source.Source<org.apache.flink.types.Row,StreamLayerRowSplit,Collection<StreamLayerRowSplit>>, org.apache.flink.api.connector.source.SourceReaderFactory<org.apache.flink.types.Row,StreamLayerRowSplit>

public class StreamLayerRowRichSource
extends Object
implements org.apache.flink.api.connector.source.Source<org.apache.flink.types.Row,StreamLayerRowSplit,Collection<StreamLayerRowSplit>>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
StreamLayerRowRichSource(HRN hrn, Settings settings, String layer, PartitionConverter partitionConverter, ConsumerSettings consumerSettings, ReadEngineFactory readEngineFactory, QueryApiFactory queryApiFactory)

Method Summary

Modifier and Type	Method	Description
static ConsumerSettings	applyCheckpointAwareCommitSettings(ConsumerSettings consumerSettings, boolean checkpointing)
org.apache.flink.api.connector.source.SplitEnumerator<StreamLayerRowSplit,Collection<StreamLayerRowSplit>>	createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<StreamLayerRowSplit> enumContext)
org.apache.flink.api.connector.source.SourceReader<org.apache.flink.types.Row,StreamLayerRowSplit>	createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)
org.apache.flink.api.connector.source.Boundedness	getBoundedness()
org.apache.flink.core.io.SimpleVersionedSerializer<Collection<StreamLayerRowSplit>>	getEnumeratorCheckpointSerializer()
org.apache.flink.core.io.SimpleVersionedSerializer<StreamLayerRowSplit>	getSplitSerializer()
org.apache.flink.api.connector.source.SplitEnumerator<StreamLayerRowSplit,Collection<StreamLayerRowSplit>>	restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<StreamLayerRowSplit> enumContext, Collection<StreamLayerRowSplit> 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

StreamLayerRowRichSource

public StreamLayerRowRichSource(HRN hrn,
 Settings settings,
 String layer,
 PartitionConverter partitionConverter,
 ConsumerSettings consumerSettings,
 ReadEngineFactory readEngineFactory,
 QueryApiFactory queryApiFactory)

Method Details

applyCheckpointAwareCommitSettings

public static ConsumerSettings applyCheckpointAwareCommitSettings(ConsumerSettings consumerSettings,
 boolean checkpointing)

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,StreamLayerRowSplit,Collection<StreamLayerRowSplit>>

createReader

public org.apache.flink.api.connector.source.SourceReader<org.apache.flink.types.Row,StreamLayerRowSplit> 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,StreamLayerRowSplit>

createEnumerator

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

Specified by:

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

restoreEnumerator

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

Specified by:

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

getSplitSerializer

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

Specified by:

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

getEnumeratorCheckpointSerializer

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

Specified by:

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