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

Class DefaultStreamLayerSourceFunctionFactoryImpl

java.lang.Object

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

public class DefaultStreamLayerSourceFunctionFactoryImpl
extends Object

Constructor Summary

Constructors

Constructor	Description
DefaultStreamLayerSourceFunctionFactoryImpl()

Method Summary

Modifier and Type	Method	Description
static 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)
static ReadEngineFactory	create$default$5()
static QueryApiFactory	create$default$6()

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultStreamLayerSourceFunctionFactoryImpl

public DefaultStreamLayerSourceFunctionFactoryImpl()

Method Details

create

public static 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)

create$default$5

public static ReadEngineFactory create$default$5()

create$default$6

public static QueryApiFactory create$default$6()