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

Class InteractiveMapLayerTableSink

java.lang.Object

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

All Implemented Interfaces:

org.apache.flink.table.connector.sink.abilities.SupportsOverwrite, org.apache.flink.table.connector.sink.DynamicTableSink

public class InteractiveMapLayerTableSink
extends Object
implements org.apache.flink.table.connector.sink.DynamicTableSink, org.apache.flink.table.connector.sink.abilities.SupportsOverwrite

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.sink.DynamicTableSink

org.apache.flink.table.connector.sink.DynamicTableSink.Context, org.apache.flink.table.connector.sink.DynamicTableSink.DataStructureConverter, org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider

Constructor Summary

Constructors

Constructor	Description
InteractiveMapLayerTableSink(HRN hrn, String layerId, InteractiveMapSchema schema, long layerRefreshInterval, long aggregationInterval, int writeParallelism, long writeTimeout, org.apache.flink.table.catalog.DataTypeFactory dataTypeFactory, DataClientFlinkContextFactory contextFactory, PublishApiFactory publishApiFactory)

Method Summary

Modifier and Type	Method	Description
void	applyOverwrite(boolean overwrite)
String	asSummaryString()
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	consumeRowStream(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.types.Row> dataStream)
org.apache.flink.table.connector.sink.DynamicTableSink	copy()
org.apache.flink.table.connector.ChangelogMode	getChangelogMode(org.apache.flink.table.connector.ChangelogMode requestedMode)
org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider	getSinkRuntimeProvider(org.apache.flink.table.connector.sink.DynamicTableSink.Context context)

Methods inherited from class java.lang.Object

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

Constructor Details

InteractiveMapLayerTableSink

public InteractiveMapLayerTableSink(HRN hrn,
 String layerId,
 InteractiveMapSchema schema,
 long layerRefreshInterval,
 long aggregationInterval,
 int writeParallelism,
 long writeTimeout,
 org.apache.flink.table.catalog.DataTypeFactory dataTypeFactory,
 DataClientFlinkContextFactory contextFactory,
 PublishApiFactory publishApiFactory)

Method Details

copy

public org.apache.flink.table.connector.sink.DynamicTableSink copy()

Specified by:

copy in interface org.apache.flink.table.connector.sink.DynamicTableSink

asSummaryString

public String asSummaryString()

Specified by:

asSummaryString in interface org.apache.flink.table.connector.sink.DynamicTableSink

getChangelogMode

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

Specified by:

getChangelogMode in interface org.apache.flink.table.connector.sink.DynamicTableSink

getSinkRuntimeProvider

public org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider getSinkRuntimeProvider(org.apache.flink.table.connector.sink.DynamicTableSink.Context context)

Specified by:

getSinkRuntimeProvider in interface org.apache.flink.table.connector.sink.DynamicTableSink

consumeRowStream

public org.apache.flink.streaming.api.datastream.DataStreamSink<?> consumeRowStream(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.types.Row> dataStream)

applyOverwrite

public void applyOverwrite(boolean overwrite)

Specified by:

applyOverwrite in interface org.apache.flink.table.connector.sink.abilities.SupportsOverwrite