Class DummyMap<InputType,OutputType>
- java.lang.Object
-
- org.apache.wayang.flink.compiler.criterion.DummyMap<InputType,OutputType>
-
- All Implemented Interfaces:
java.io.Serializable
,org.apache.flink.api.common.functions.Function
,org.apache.flink.api.common.functions.MapFunction<InputType,OutputType>
,org.apache.flink.api.java.typeutils.ResultTypeQueryable<OutputType>
public class DummyMap<InputType,OutputType> extends java.lang.Object implements org.apache.flink.api.common.functions.MapFunction<InputType,OutputType>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<OutputType>
Class create aMapFunction
that genereta only null as convertion- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description java.lang.Class<InputType>
inputTypeClass
java.lang.Class<OutputType>
outputTypeClass
-
Constructor Summary
Constructors Constructor Description DummyMap(java.lang.Class<InputType> inputTypeClass, java.lang.Class<OutputType> outputTypeClass)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.flink.api.common.typeinfo.TypeInformation<OutputType>
getProducedType()
OutputType
map(InputType inputType)
-
-
-
Field Detail
-
inputTypeClass
public final java.lang.Class<InputType> inputTypeClass
-
outputTypeClass
public final java.lang.Class<OutputType> outputTypeClass
-
-
Constructor Detail
-
DummyMap
public DummyMap(java.lang.Class<InputType> inputTypeClass, java.lang.Class<OutputType> outputTypeClass)
-
-
Method Detail
-
map
public OutputType map(InputType inputType) throws java.lang.Exception
- Specified by:
map
in interfaceorg.apache.flink.api.common.functions.MapFunction<InputType,OutputType>
- Throws:
java.lang.Exception
-
getProducedType
public org.apache.flink.api.common.typeinfo.TypeInformation<OutputType> getProducedType()
- Specified by:
getProducedType
in interfaceorg.apache.flink.api.java.typeutils.ResultTypeQueryable<InputType>
-
-