Package uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.javardd

Class GetJavaRDDOfElementsInRangesHandler

java.lang.Object

uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.AbstractGetRDDHandler<GetJavaRDDOfElementsInRanges,org.apache.spark.api.java.JavaRDD<Element>>

uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.javardd.GetJavaRDDOfElementsInRangesHandler

All Implemented Interfaces:

OperationHandler<GetJavaRDDOfElementsInRanges>, OutputOperationHandler<GetJavaRDDOfElementsInRanges,org.apache.spark.api.java.JavaRDD<Element>>

public class GetJavaRDDOfElementsInRangesHandler
extends AbstractGetRDDHandler<GetJavaRDDOfElementsInRanges,org.apache.spark.api.java.JavaRDD<Element>>

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
GetJavaRDDOfElementsInRangesHandler()

Method Summary

Modifier and Type	Method	Description
org.apache.spark.api.java.JavaRDD<Element>	doOperation(GetJavaRDDOfElementsInRanges operation, Context context, Store store)	Execute the given Output operation.

Methods inherited from class uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.AbstractGetRDDHandler

addIterators, addRanges, addRangesFromPairs, convertConfigurationToString, convertStringToConfiguration

Methods inherited from class java.lang.Object

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

Constructor Detail

GetJavaRDDOfElementsInRangesHandler

public GetJavaRDDOfElementsInRangesHandler()

Method Detail

doOperation

public org.apache.spark.api.java.JavaRDD<Element> doOperation(GetJavaRDDOfElementsInRanges operation,
                                                              Context context,
                                                              Store store)
                                                       throws OperationException

Description copied from interface: OutputOperationHandler

Execute the given Output operation.

Parameters:

operation - the Output 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.

Throws:

OperationException - thrown if the operation fails