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

Class GetJavaRDDOfElementsHandler

java.lang.Object

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

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

All Implemented Interfaces:

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

public class GetJavaRDDOfElementsHandler
extends AbstractGetRDDHandler<GetJavaRDDOfElements,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
GetJavaRDDOfElementsHandler()

Method Summary

Modifier and Type	Method	Description
org.apache.spark.api.java.JavaRDD<Element>	doOperation(GetJavaRDDOfElements 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

GetJavaRDDOfElementsHandler

public GetJavaRDDOfElementsHandler()

Method Detail

doOperation

public org.apache.spark.api.java.JavaRDD<Element> doOperation(GetJavaRDDOfElements 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