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

Class FeatureReduceWindow

java.lang.Object

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

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.ReduceFunction<InteractiveMapFeaturePojo>

public class FeatureReduceWindow
extends Object
implements org.apache.flink.api.common.functions.ReduceFunction<InteractiveMapFeaturePojo>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
FeatureReduceWindow()

Method Summary

Modifier and Type	Method	Description
InteractiveMapFeaturePojo	reduce(InteractiveMapFeaturePojo first, InteractiveMapFeaturePojo second)

Methods inherited from class java.lang.Object

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

Constructor Details

FeatureReduceWindow

public FeatureReduceWindow()

Method Details

reduce

public InteractiveMapFeaturePojo reduce(InteractiveMapFeaturePojo first,
 InteractiveMapFeaturePojo second)

Specified by:

reduce in interface org.apache.flink.api.common.functions.ReduceFunction<InteractiveMapFeaturePojo>