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

Class AbstractGetRDDHandler<OP extends Output<O> & GraphFilters,O>

java.lang.Object

uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.AbstractGetRDDHandler<OP,O>

All Implemented Interfaces:

OperationHandler<OP>, OutputOperationHandler<OP,O>

Direct Known Subclasses:

GetJavaRDDOfAllElementsHandler, GetJavaRDDOfElementsHandler, GetJavaRDDOfElementsInRangesHandler, GetRDDOfAllElementsHandler, GetRDDOfElementsHandler, GetRDDOfElementsInRangesHandler

public abstract class AbstractGetRDDHandler<OP extends Output<O> & GraphFilters,O>
extends Object
implements OutputOperationHandler<OP,O>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AbstractGetRDDHandler.FirstElement

Field Summary

Fields

Modifier and Type	Field	Description
static String	HADOOP_CONFIGURATION_KEY
static String	USE_BATCH_SCANNER_RDD
static String	USE_RFILE_READER_RDD
static String	VIEW

Constructor Summary

Constructors

Constructor	Description
AbstractGetRDDHandler()

Method Summary

Modifier and Type	Method	Description
void	addIterators(AccumuloStore accumuloStore, org.apache.hadoop.conf.Configuration conf, User user, OP operation)
<INPUT_OP extends Operation & GraphFilters & Input<Iterable<? extends ElementId>>> void	addRanges(AccumuloStore accumuloStore, org.apache.hadoop.conf.Configuration conf, INPUT_OP operation)
<INPUT_OP extends Operation & GraphFilters & Input<Iterable<? extends Pair<? extends ElementId,? extends ElementId>>>> void	addRangesFromPairs(AccumuloStore accumuloStore, org.apache.hadoop.conf.Configuration conf, INPUT_OP operation)
static String	convertConfigurationToString(org.apache.hadoop.conf.Configuration conf)
static org.apache.hadoop.conf.Configuration	convertStringToConfiguration(String encodedConf)

Methods inherited from class java.lang.Object

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

Methods inherited from interface uk.gov.gchq.gaffer.store.operation.handler.OutputOperationHandler

doOperation

Field Detail

HADOOP_CONFIGURATION_KEY

public static final String HADOOP_CONFIGURATION_KEY

See Also:

Constant Field Values

USE_RFILE_READER_RDD

public static final String USE_RFILE_READER_RDD

See Also:

Constant Field Values

VIEW

public static final String VIEW

See Also:

Constant Field Values

USE_BATCH_SCANNER_RDD

public static final String USE_BATCH_SCANNER_RDD

See Also:

Constant Field Values

Constructor Detail

AbstractGetRDDHandler

public AbstractGetRDDHandler()

Method Detail

addIterators

public void addIterators(AccumuloStore accumuloStore,
                         org.apache.hadoop.conf.Configuration conf,
                         User user,
                         OP operation)
                  throws OperationException

Throws:

OperationException

addRanges

public <INPUT_OP extends Operation & GraphFilters & Input<Iterable<? extends ElementId>>> void addRanges(AccumuloStore accumuloStore,
                                                                                                         org.apache.hadoop.conf.Configuration conf,
                                                                                                         INPUT_OP operation)
                                                                                                  throws OperationException

Throws:

OperationException

addRangesFromPairs

public <INPUT_OP extends Operation & GraphFilters & Input<Iterable<? extends Pair<? extends ElementId,? extends ElementId>>>> void addRangesFromPairs(AccumuloStore accumuloStore,
                                                                                                                                                            org.apache.hadoop.conf.Configuration conf,
                                                                                                                                                            INPUT_OP operation)
                                                                                                                                                     throws OperationException

Throws:

OperationException

convertConfigurationToString

public static String convertConfigurationToString(org.apache.hadoop.conf.Configuration conf)
                                           throws IOException

Throws:

IOException

convertStringToConfiguration

public static org.apache.hadoop.conf.Configuration convertStringToConfiguration(String encodedConf)
                                                                         throws IOException

Throws:

IOException