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

Class VersionLayerTableSource

java.lang.Object

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

All Implemented Interfaces:

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

public class VersionLayerTableSource
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
VersionLayerTableSource(HRN hrn, String layerId, String query, PartitionSchema schema, int readBatchSize, long timeOut, boolean isContinuouslyRead, int partNumbers, org.apache.flink.table.catalog.DataTypeFactory dataTypeFactory, ReadEngineFactory readEngineFactory, QueryApiFactory queryApiFactory)

Method Summary

Modifier and Type	Method	Description
String	asSummaryString()
VersionLayerTableSource	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

VersionLayerTableSource

public VersionLayerTableSource(HRN hrn,
 String layerId,
 String query,
 PartitionSchema schema,
 int readBatchSize,
 long timeOut,
 boolean isContinuouslyRead,
 int partNumbers,
 org.apache.flink.table.catalog.DataTypeFactory dataTypeFactory,
 ReadEngineFactory readEngineFactory,
 QueryApiFactory queryApiFactory)

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 VersionLayerTableSource 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)