Class DefaultStreamLayerSourceFunctionFactoryImpl
java.lang.Object
com.here.platform.data.client.flink.impl.DefaultStreamLayerSourceFunctionFactoryImpl
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic 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 ReadEngineFactorystatic QueryApiFactory
-
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
-
create$default$6
-