Modifier and Type | Method and Description |
---|---|
abstract Stage<?,?,?,?,?,?,?,?> |
StageRunner.stage() |
Stage<?,?,?,?,?,?,?,?> |
SingleStagedJob.stage() |
Modifier and Type | Method and Description |
---|---|
void |
MultiStagedJob.queueStage(Stage<?,?,?,?,?,?,?,?> s)
Add a stage to the end of the queue of stages.
|
void |
SingleStagedJob.setStage(Stage<?,?,?,?,?,?,?,?> stage) |
Constructor and Description |
---|
SingleStagedJob(Stage<?,?,?,?,?,?,?,?> s,
org.apache.hadoop.fs.Path[] inputs,
org.apache.hadoop.fs.Path output) |
Modifier and Type | Method and Description |
---|---|
abstract Stage<?,?,?,?,?,?,?,?> |
StageProvider.stage() |
Modifier and Type | Class and Description |
---|---|
class |
MultipleOutputStage<INPUT_FORMAT extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat<INPUT_KEY,INPUT_VALUE>,INPUT_KEY,INPUT_VALUE,MAP_OUTPUT_KEY,MAP_OUTPUT_VALUE,OUTPUT_KEY,OUTPUT_VALUE>
A helper class for a common stage type.
|
class |
SequenceFileStage<INPUT_KEY,INPUT_VALUE,MAP_OUTPUT_KEY,MAP_OUTPUT_VALUE,OUTPUT_KEY,OUTPUT_VALUE>
A helper class for a common stage type.
|
class |
SequenceFileTextStage<INPUT_KEY,INPUT_VALUE,MAP_OUTPUT_KEY,MAP_OUTPUT_VALUE,OUTPUT_KEY,OUTPUT_VALUE>
A helper class for a common stage type.
|
class |
SimpleSequenceFileStage<INPUT_KEY,INPUT_VALUE,OUTPUT_KEY,OUTPUT_VALUE>
A helper class for a common stage type.
|
class |
SimpleSequenceFileTextStage<INPUT_KEY,INPUT_VALUE,OUTPUT_KEY,OUTPUT_VALUE>
A helper class for a common stage type.
|
class |
TextByteByteStage
A helper class for a common stage type.
|
class |
TextLongByteStage
A helper class for a common stage type.
|
class |
TextSequenceFileStage<MAP_OUTPUT_KEY,MAP_OUTPUT_VALUE,OUTPUT_KEY,OUTPUT_VALUE>
A helper class for a common stage type.
|
class |
TextSomethingTextStage<MAPOUTKEY,MAPOUTVALUE>
A helper class for a common stage type.
|
class |
TextStage
A stage that takes text in and spits text out
|
class |
TextTextByteStage
A helper class for a common stage type.
|
Modifier and Type | Class and Description |
---|---|
class |
TextDaySplitStage |
Modifier and Type | Method and Description |
---|---|
Stage<?,?,?,?,?,?,?,?> |
HadoopTwitterPreprocessingTool.stage() |
Modifier and Type | Class and Description |
---|---|
class |
TokenRegexStage
If tokens in set of terms spit out the whole line, otherwise ignore.
|
Modifier and Type | Class and Description |
---|---|
class |
PairMutualInformation |
Modifier and Type | Class and Description |
---|---|
class |
PMIPairSort
Sort pairs by PMI within timeperiods
|
Modifier and Type | Class and Description |
---|---|
class |
CorrelateWordSort |
class |
CorrelateWordTimeSeries |
Modifier and Type | Class and Description |
---|---|
class |
TimeWordJacardIndex
Count word instances (not occurences) across times.
|