Class GafferMapFunction<T>
- java.lang.Object
-
- uk.gov.gchq.gaffer.flink.operation.handler.GafferMapFunction<T>
-
- All Implemented Interfaces:
Serializable
,org.apache.flink.api.common.functions.FlatMapFunction<T,Element>
,org.apache.flink.api.common.functions.Function
public class GafferMapFunction<T> extends Object implements org.apache.flink.api.common.functions.FlatMapFunction<T,Element>
Implementation ofFlatMapFunction
to allow CSV strings representingElement
s to be mapped to Element objects.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description GafferMapFunction()
GafferMapFunction(Class<T> consumeAs, Class<? extends Function<Iterable<? extends T>,Iterable<? extends Element>>> generatorClassName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
flatMap(T item, org.apache.flink.util.Collector<Element> out)
org.apache.flink.streaming.util.serialization.DeserializationSchema<T>
getSerialisationType()
void
setConsumeAs(Class<T> consumeAs)
-