public class CorrelateWordTimeSeries extends SequenceFileTextStage<org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>
Modifier and Type | Field and Description |
---|---|
static String |
CORRELATE_WORDTIME
the directory this stage will output
|
static String |
FINANCE_DATA |
static String |
PERIOD_END |
static String |
PERIOD_START |
Constructor and Description |
---|
CorrelateWordTimeSeries(String financelocation,
IndependentPair<Long,Long> startend) |
Modifier and Type | Method and Description |
---|---|
Class<? extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>> |
mapper()
By default this method returns the
IdentityMapper class. |
String |
outname() |
void |
setup(org.apache.hadoop.mapreduce.Job job)
Add any final adjustments to the job's config
|
combiner, finished, lzoCompress, reducer, setCombinerClass, setMapperClass, setReducerClass, stage
public static final String CORRELATE_WORDTIME
public static final String PERIOD_START
public static final String PERIOD_END
public static final String FINANCE_DATA
public CorrelateWordTimeSeries(String financelocation, IndependentPair<Long,Long> startend)
public void setup(org.apache.hadoop.mapreduce.Job job)
Stage
setup
in class Stage<org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable>,org.apache.hadoop.mapreduce.lib.output.TextOutputFormat<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>,org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>
public String outname()
outname
in class Stage<org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable>,org.apache.hadoop.mapreduce.lib.output.TextOutputFormat<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>,org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>
public Class<? extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>> mapper()
Stage
IdentityMapper
class. This
mapper outputs the values handed as they are.mapper
in class Stage<org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable>,org.apache.hadoop.mapreduce.lib.output.TextOutputFormat<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>,org.apache.hadoop.io.Text,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text>