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

Class VolatileLayerSubmitWindow

java.lang.Object

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

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

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

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.AllWindowFunction<com.here.platform.data.client.scaladsl.CommitPartition,Object,org.apache.flink.streaming.api.windowing.windows.TimeWindow>

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

See Also:

• Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	apply(org.apache.flink.streaming.api.windowing.windows.TimeWindow window, Iterable<com.here.platform.data.client.scaladsl.CommitPartition> partitions, org.apache.flink.util.Collector<Object> 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

Constructor Details

VolatileLayerSubmitWindow

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

Method Details

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

apply

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