Package uk.gov.gchq.gaffer.flink.operation.handler

Class GafferSink

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction, org.apache.flink.streaming.api.functions.sink.SinkFunction<Element>
    public class GafferSink
extends org.apache.flink.streaming.api.functions.sink.RichSinkFunction<Element>
    See Also:
    Serialized Form

    • Nested Class Summary

      • Nested classes/interfaces inherited from interface org.apache.flink.streaming.api.functions.sink.SinkFunction

        org.apache.flink.streaming.api.functions.sink.SinkFunction.Context<T extends Object>

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void invoke​(Element element)  
      void open​(org.apache.flink.configuration.Configuration parameters)  

      • Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

        close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext

      • Methods inherited from interface org.apache.flink.streaming.api.functions.sink.SinkFunction

        invoke

    • Constructor Detail

      • GafferSink

        public GafferSink​(OP validatable,
                  Store store)

    • Method Detail

      • open

        public void open​(org.apache.flink.configuration.Configuration parameters)
          throws Exception
        Specified by:
        open in interface org.apache.flink.api.common.functions.RichFunction
        Overrides:
        open in class org.apache.flink.api.common.functions.AbstractRichFunction
        Throws:
        Exception