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

Class AddElementsFromFileHandler

java.lang.Object

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

All Implemented Interfaces:

OperationHandler<AddElementsFromFile>

public class AddElementsFromFileHandler
extends Object
implements OperationHandler<AddElementsFromFile>

A AddElementsFromFileHandler handles the AddElementsFromFile operation.

This uses Flink to stream the Element objects from a file into Gaffer.

Rebalancing can be skipped by setting the operation option: gaffer.flink.operation.handler.skip-rebalancing to true

Constructor Summary

Constructors

Constructor	Description
AddElementsFromFileHandler()
AddElementsFromFileHandler(org.apache.flink.api.common.io.RichOutputFormat<Element> outputFormat)

Method Summary

Modifier and Type	Method	Description
Object	doOperation(AddElementsFromFile op, Context context, Store store)	Execute the given Operation.

Methods inherited from class java.lang.Object

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

Constructor Detail

AddElementsFromFileHandler

public AddElementsFromFileHandler()

AddElementsFromFileHandler

public AddElementsFromFileHandler(org.apache.flink.api.common.io.RichOutputFormat<Element> outputFormat)

Method Detail

doOperation

public Object doOperation(AddElementsFromFile op,
                          Context context,
                          Store store)
                   throws OperationException

Description copied from interface: OperationHandler

Execute the given Operation.

Specified by:

doOperation in interface OperationHandler<AddElementsFromFile>

Parameters:

op - the Operation to be executed

context - the operation chain context, containing the user who executed the operation

store - the Store the operation should be run on

Returns:

the output for the operation or null.

Throws:

OperationException - thrown if the operation fails