Class GetRDDOfElementsInRangesHandler
- java.lang.Object
-
- uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.AbstractGetRDDHandler<GetRDDOfElementsInRanges,org.apache.spark.rdd.RDD<Element>>
-
- uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.scalardd.GetRDDOfElementsInRangesHandler
-
- All Implemented Interfaces:
OperationHandler<GetRDDOfElementsInRanges>
,OutputOperationHandler<GetRDDOfElementsInRanges,org.apache.spark.rdd.RDD<Element>>
public class GetRDDOfElementsInRangesHandler extends AbstractGetRDDHandler<GetRDDOfElementsInRanges,org.apache.spark.rdd.RDD<Element>>
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.AbstractGetRDDHandler
AbstractGetRDDHandler.FirstElement
-
-
Field Summary
-
Fields inherited from class uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.AbstractGetRDDHandler
HADOOP_CONFIGURATION_KEY, USE_BATCH_SCANNER_RDD, USE_RFILE_READER_RDD, VIEW
-
-
Constructor Summary
Constructors Constructor Description GetRDDOfElementsInRangesHandler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.spark.rdd.RDD<Element>
doOperation(GetRDDOfElementsInRanges operation, Context context, Store store)
Execute the givenOutput
operation.-
Methods inherited from class uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.AbstractGetRDDHandler
addIterators, addRanges, addRangesFromPairs, convertConfigurationToString, convertStringToConfiguration
-
-
-
-
Method Detail
-
doOperation
public org.apache.spark.rdd.RDD<Element> doOperation(GetRDDOfElementsInRanges operation, Context context, Store store) throws OperationException
Description copied from interface:OutputOperationHandler
Execute the givenOutput
operation.- Parameters:
operation
- theOutput
operation 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.
- Throws:
OperationException
- thrown if the operation fails
-
-