de.kumpe.hadooptimizer.hadoop
Class IndividualInputFormat<I extends Serializable>

java.lang.Object
  org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.DoubleWritable,I>
      de.kumpe.hadooptimizer.hadoop.IndividualInputFormat<I>

Type Parameters:

I - the individuals's type

public final class IndividualInputFormat<I extends Serializable>
extends org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.DoubleWritable,I>

A special InputFormat implementation to control the distribution of the individuals for mutation and evaluation.

Author:

Christian Kumpe

See Also:

EaHadoOptimizer, EsHadoOptimizer

Nested Class Summary

static class

IndividualInputFormat.IndividualInputSplit<I extends Serializable>

Constructor Summary

IndividualInputFormat()

Method Summary

org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.DoubleWritable,I>	createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
List<org.apache.hadoop.mapreduce.InputSplit>	getSplits(org.apache.hadoop.mapreduce.JobContext context)
static void	setInputPaths(org.apache.hadoop.mapreduce.Job job, org.apache.hadoop.fs.Path... inputPaths)
static void	setOffspring(org.apache.hadoop.mapreduce.Job job, int duplicationFactor)
static void	setRandomChoice(org.apache.hadoop.mapreduce.Job job, boolean randomChoice)
static void	setRandomGeneratorFactory(org.apache.hadoop.mapreduce.Job job, RandomGeneratorFactory randomGeneratorFactory, long seed)
static void	setSplits(org.apache.hadoop.mapreduce.Job job, int maxNrOfSplits)

Methods inherited from class java.lang.Object

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

Constructor Detail

IndividualInputFormat

public IndividualInputFormat()

Method Detail

setInputPaths

public static void setInputPaths(org.apache.hadoop.mapreduce.Job job,
                                 org.apache.hadoop.fs.Path... inputPaths)
                          throws IOException

Throws:

IOException

setOffspring

public static void setOffspring(org.apache.hadoop.mapreduce.Job job,
                                int duplicationFactor)

setSplits

public static void setSplits(org.apache.hadoop.mapreduce.Job job,
                             int maxNrOfSplits)

setRandomGeneratorFactory

public static void setRandomGeneratorFactory(org.apache.hadoop.mapreduce.Job job,
                                             RandomGeneratorFactory randomGeneratorFactory,
                                             long seed)

setRandomChoice

public static void setRandomChoice(org.apache.hadoop.mapreduce.Job job,
                                   boolean randomChoice)

getSplits

public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context)
                                                       throws IOException,
                                                              InterruptedException

Specified by:

getSplits in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.DoubleWritable,I extends Serializable>

Throws:

IOException

InterruptedException

createRecordReader

public org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.DoubleWritable,I> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                                                          org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                                                                        throws IOException,
                                                                                                                               InterruptedException

Specified by:

createRecordReader in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.DoubleWritable,I extends Serializable>

Throws:

IOException

InterruptedException