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

Class InteractiveMapLayerTableSource

java.lang.Object

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

All Implemented Interfaces:

org.apache.flink.table.connector.source.DynamicTableSource, org.apache.flink.table.connector.source.ScanTableSource

public class InteractiveMapLayerTableSource
extends Object
implements org.apache.flink.table.connector.source.ScanTableSource

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.source.DynamicTableSource

org.apache.flink.table.connector.source.DynamicTableSource.Context, org.apache.flink.table.connector.source.DynamicTableSource.DataStructureConverter

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.source.ScanTableSource

org.apache.flink.table.connector.source.ScanTableSource.ScanContext, org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider

Constructor Summary

Constructors

Constructor

Description

InteractiveMapLayerTableSource(HRN hrn, String layerId, String query, boolean ignoreInvalidPartitions, InteractiveMapSchema schema, long layerRefreshInterval, int readParallelism, int readMaxFeaturesPerRequest, long readTimeout, org.apache.flink.table.catalog.DataTypeFactory dataTypeFactory, DataClientFlinkContextFactory contextFactory, QueryApiFactory queryApiFactory, PublishApiFactory publishApiFactory)

Method Summary

Modifier and Type	Method	Description
String	asSummaryString()
InteractiveMapLayerTableSource	copy()
org.apache.flink.table.types.DataType	dataType()
org.apache.flink.table.connector.ChangelogMode	getChangelogMode()
org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider	getScanRuntimeProvider(org.apache.flink.table.connector.source.ScanTableSource.ScanContext ctx)
org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.types.Row>	produceDataStreamRow(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv)

Methods inherited from class java.lang.Object

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

Constructor Details

InteractiveMapLayerTableSource

public InteractiveMapLayerTableSource(HRN hrn,
 String layerId,
 String query,
 boolean ignoreInvalidPartitions,
 InteractiveMapSchema schema,
 long layerRefreshInterval,
 int readParallelism,
 int readMaxFeaturesPerRequest,
 long readTimeout,
 org.apache.flink.table.catalog.DataTypeFactory dataTypeFactory,
 DataClientFlinkContextFactory contextFactory,
 QueryApiFactory queryApiFactory,
 PublishApiFactory publishApiFactory)

Method Details

getChangelogMode

public org.apache.flink.table.connector.ChangelogMode getChangelogMode()

Specified by:

getChangelogMode in interface org.apache.flink.table.connector.source.ScanTableSource

asSummaryString

public String asSummaryString()

Specified by:

asSummaryString in interface org.apache.flink.table.connector.source.DynamicTableSource

dataType

public org.apache.flink.table.types.DataType dataType()

copy

public InteractiveMapLayerTableSource copy()

Specified by:

copy in interface org.apache.flink.table.connector.source.DynamicTableSource

getScanRuntimeProvider

public org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider getScanRuntimeProvider(org.apache.flink.table.connector.source.ScanTableSource.ScanContext ctx)

Specified by:

getScanRuntimeProvider in interface org.apache.flink.table.connector.source.ScanTableSource

produceDataStreamRow

public org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.types.Row> produceDataStreamRow(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv)