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

Class FeaturePojoToRowMapper

java.lang.Object

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

org.apache.flink.api.common.functions.RichMapFunction<InteractiveMapFeaturePojo,org.apache.flink.types.Row>

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

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.MapFunction<InteractiveMapFeaturePojo,org.apache.flink.types.Row>, org.apache.flink.api.common.functions.RichFunction

public class FeaturePojoToRowMapper
extends org.apache.flink.api.common.functions.RichMapFunction<InteractiveMapFeaturePojo,org.apache.flink.types.Row>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
FeaturePojoToRowMapper(InteractiveMapSchema schema)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.types.Row	map(InteractiveMapFeaturePojo feature)

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

FeaturePojoToRowMapper

public FeaturePojoToRowMapper(InteractiveMapSchema schema)

Method Details

map

public org.apache.flink.types.Row map(InteractiveMapFeaturePojo feature)

Specified by:

map in interface org.apache.flink.api.common.functions.MapFunction<InteractiveMapFeaturePojo,org.apache.flink.types.Row>

Specified by:

map in class org.apache.flink.api.common.functions.RichMapFunction<InteractiveMapFeaturePojo,org.apache.flink.types.Row>