Class 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 of FlatMapFunction to allow CSV strings representing Elements to be mapped to Element objects.
    See Also:
    Serialized Form
    • Constructor Detail

      • GafferMapFunction

        public GafferMapFunction()
    • Method Detail

      • setConsumeAs

        public void setConsumeAs​(Class<T> consumeAs)
      • flatMap

        public void flatMap​(T item,
                            org.apache.flink.util.Collector<Element> out)
                     throws Exception
        Specified by:
        flatMap in interface org.apache.flink.api.common.functions.FlatMapFunction<T,​Element>
        Throws:
        Exception
      • getSerialisationType

        public org.apache.flink.streaming.util.serialization.DeserializationSchema<T> getSerialisationType()