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

Class GetRDDOfElementsHandler

java.lang.Object

uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.AbstractGetRDDHandler<GetRDDOfElements,org.apache.spark.rdd.RDD<Element>>

uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.scalardd.GetRDDOfElementsHandler

All Implemented Interfaces:

OperationHandler<GetRDDOfElements>, OutputOperationHandler<GetRDDOfElements,org.apache.spark.rdd.RDD<Element>>

public class GetRDDOfElementsHandler
extends AbstractGetRDDHandler<GetRDDOfElements,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
GetRDDOfElementsHandler()

Method Summary

Modifier and Type	Method	Description
org.apache.spark.rdd.RDD<Element>	doOperation(GetRDDOfElements 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

GetRDDOfElementsHandler

public GetRDDOfElementsHandler()

Method Detail

doOperation

public org.apache.spark.rdd.RDD<Element> doOperation(GetRDDOfElements 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