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

Class IndexLayerSubmitWindow

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.streaming.api.functions.windowing.RichWindowFunction<com.here.platform.data.client.scaladsl.CommitPartition,String,Object,org.apache.flink.streaming.api.windowing.windows.TimeWindow>

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

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction, org.apache.flink.streaming.api.functions.windowing.WindowFunction<com.here.platform.data.client.scaladsl.CommitPartition,String,Object,org.apache.flink.streaming.api.windowing.windows.TimeWindow>

public class IndexLayerSubmitWindow
extends org.apache.flink.streaming.api.functions.windowing.RichWindowFunction<com.here.platform.data.client.scaladsl.CommitPartition,String,Object,org.apache.flink.streaming.api.windowing.windows.TimeWindow>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
IndexLayerSubmitWindow(HRN hrn, String layerId, scala.Option<com.here.platform.data.client.scaladsl.PublishApi> publishApi)

Method Summary

Modifier and Type	Method	Description
void	apply(int key, org.apache.flink.streaming.api.windowing.windows.TimeWindow window, Iterable<com.here.platform.data.client.scaladsl.CommitPartition> partitions, org.apache.flink.util.Collector<String> out)
void	close()

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.streaming.api.functions.windowing.WindowFunction

apply

Constructor Details

IndexLayerSubmitWindow

public IndexLayerSubmitWindow(HRN hrn,
 String layerId,
 scala.Option<com.here.platform.data.client.scaladsl.PublishApi> publishApi)

Method Details

apply

public void apply(int key,
 org.apache.flink.streaming.api.windowing.windows.TimeWindow window,
 Iterable<com.here.platform.data.client.scaladsl.CommitPartition> partitions,
 org.apache.flink.util.Collector<String> out)

close

public void close()

Specified by:

close in interface org.apache.flink.api.common.functions.RichFunction

Overrides:

close in class org.apache.flink.api.common.functions.AbstractRichFunction