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

Class FeatureDeleteSideOutputFunction

java.lang.Object

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

org.apache.flink.streaming.api.functions.ProcessFunction<InteractiveMapFeaturePojo,InteractiveMapFeaturePojo>

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

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction

public class FeatureDeleteSideOutputFunction
extends org.apache.flink.streaming.api.functions.ProcessFunction<InteractiveMapFeaturePojo,InteractiveMapFeaturePojo>

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.streaming.api.functions.ProcessFunction

org.apache.flink.streaming.api.functions.ProcessFunction.Context, org.apache.flink.streaming.api.functions.ProcessFunction.OnTimerContext

Constructor Summary

Constructors

Constructor	Description
FeatureDeleteSideOutputFunction()

Method Summary

Modifier and Type	Method	Description
void	processElement(InteractiveMapFeaturePojo input, org.apache.flink.streaming.api.functions.ProcessFunction<InteractiveMapFeaturePojo,InteractiveMapFeaturePojo>.org.apache.flink.streaming.api.functions.ProcessFunction.Context context, org.apache.flink.util.Collector<InteractiveMapFeaturePojo> out)

Methods inherited from class org.apache.flink.streaming.api.functions.ProcessFunction

onTimer

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

close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object

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

Constructor Details

FeatureDeleteSideOutputFunction

public FeatureDeleteSideOutputFunction()

Method Details

processElement

public void processElement(InteractiveMapFeaturePojo input,
 org.apache.flink.streaming.api.functions.ProcessFunction<InteractiveMapFeaturePojo,InteractiveMapFeaturePojo>.org.apache.flink.streaming.api.functions.ProcessFunction.Context context,
 org.apache.flink.util.Collector<InteractiveMapFeaturePojo> out)

Specified by:

processElement in class org.apache.flink.streaming.api.functions.ProcessFunction<InteractiveMapFeaturePojo,InteractiveMapFeaturePojo>