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

Interface StreamLayerSourceFunctionFactory

public interface StreamLayerSourceFunctionFactory

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.connector.source.Source<org.apache.flink.types.Row,? extends org.apache.flink.api.connector.source.SourceSplit,?>	create(HRN hrn, String layerId, PartitionConverter partitionConverter, ConsumerSettings consumerSettings, ReadEngineFactory readEngineFactory, QueryApiFactory queryApiFactory)

Method Details

create

org.apache.flink.api.connector.source.Source<org.apache.flink.types.Row,? extends org.apache.flink.api.connector.source.SourceSplit,?> create(HRN hrn,
 String layerId,
 PartitionConverter partitionConverter,
 ConsumerSettings consumerSettings,
 ReadEngineFactory readEngineFactory,
 QueryApiFactory queryApiFactory)