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 theAddElementsFromFile
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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Object
doOperation(AddElementsFromFile op, Context context, Store store)
Execute the givenOperation
.
-
-
-
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 givenOperation
.- Specified by:
doOperation
in interfaceOperationHandler<AddElementsFromFile>
- Parameters:
op
- theOperation
to be executedcontext
- the operation chain context, containing the user who executed the operationstore
- theStore
the operation should be run on- Returns:
- the output for the operation or null.
- Throws:
OperationException
- thrown if the operation fails
-
-