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

Class GafferOutput

java.lang.Object

org.apache.flink.api.common.io.RichOutputFormat<Element>

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

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.io.OutputFormat<Element>

public class GafferOutput
extends org.apache.flink.api.common.io.RichOutputFormat<Element>

Implementation of RichOutputFormat for Gaffer to allow Elements to be consumed from external sources.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
GafferOutput(OP validatable, Store store)
GafferOutput(GafferAdder adder)

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(org.apache.flink.configuration.Configuration parameters)
void	open(int taskNumber, int numTasks)
void	writeRecord(Element element)

Methods inherited from class org.apache.flink.api.common.io.RichOutputFormat

getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GafferOutput

public GafferOutput(OP validatable,
                    Store store)

GafferOutput

public GafferOutput(GafferAdder adder)

Method Detail

configure

public void configure(org.apache.flink.configuration.Configuration parameters)

writeRecord

public void writeRecord(Element element)

open

public void open(int taskNumber,
                 int numTasks)
          throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException