Package uk.gov.gchq.gaffer.hdfs.operation

Interface MapReduce.Builder<OP extends MapReduce,B extends MapReduce.Builder<OP,?>>

All Superinterfaces:

Operation.Builder<OP,B>

All Known Implementing Classes:

AddElementsFromHdfs.Builder, SampleDataForSplitPoints.Builder

Enclosing interface:

MapReduce

public static interface MapReduce.Builder<OP extends MapReduce,B extends MapReduce.Builder<OP,?>>
extends Operation.Builder<OP,B>

Method Summary

Modifier and Type	Method	Description
default B	addInputMapperPair(String inputPath, Class<?> mapperGeneratorClass)
default B	addInputMapperPair(String inputPath, String mapperGeneratorClassName)
default B	addInputMapperPairs(Map<String,String> inputMapperPairs)
default B	commandLineArgs(String... commandLineArgs)
default B	inputMapperPairs(Map<String,String> inputMapperPairs)
default B	jobInitialiser(JobInitialiser jobInitialiser)
default B	mappers(Integer numMapTasks)
default B	maxMappers(Integer maxMapTasks)
default B	maxReducers(Integer maxReduceTasks)
default B	minMappers(Integer minMapTasks)
default B	minReducers(Integer minReduceTasks)
default B	outputPath(String outputPath)
default B	partitioner(Class<? extends org.apache.hadoop.mapreduce.Partitioner> partitioner)
default B	splitsFilePath(String splitsFile)
default B	useProvidedSplits(boolean useProvidedSplits)

Methods inherited from interface uk.gov.gchq.gaffer.operation.Operation.Builder

_getOp, _self

Method Detail

inputMapperPairs

default B inputMapperPairs(Map<String,String> inputMapperPairs)

addInputMapperPairs

default B addInputMapperPairs(Map<String,String> inputMapperPairs)

addInputMapperPair

default B addInputMapperPair(String inputPath,
                             String mapperGeneratorClassName)

addInputMapperPair

default B addInputMapperPair(String inputPath,
                             Class<?> mapperGeneratorClass)

outputPath

default B outputPath(String outputPath)

splitsFilePath

default B splitsFilePath(String splitsFile)

useProvidedSplits

default B useProvidedSplits(boolean useProvidedSplits)

jobInitialiser

default B jobInitialiser(JobInitialiser jobInitialiser)

minReducers

default B minReducers(Integer minReduceTasks)

maxReducers

default B maxReducers(Integer maxReduceTasks)

mappers

default B mappers(Integer numMapTasks)

minMappers

default B minMappers(Integer minMapTasks)

maxMappers

default B maxMappers(Integer maxMapTasks)

partitioner

default B partitioner(Class<? extends org.apache.hadoop.mapreduce.Partitioner> partitioner)

commandLineArgs

default B commandLineArgs(String... commandLineArgs)