A C D G H I J L M N O R S T
A
- add(Object) - Method in class org.apache.hadoop.contrib.utils.join.ArrayListBackedIterator
-
- add(Object) - Method in interface org.apache.hadoop.contrib.utils.join.ResetableIterator
-
- addDoubleValue(Object, double) - Method in class org.apache.hadoop.contrib.utils.join.JobBase
-
Increment the given counter by the given incremental value If the counter
does not exist, one is created with value 0.
- addLongValue(Object, long) - Method in class org.apache.hadoop.contrib.utils.join.JobBase
-
Increment the given counter by the given incremental value If the counter
does not exist, one is created with value 0.
- ArrayListBackedIterator - Class in org.apache.hadoop.contrib.utils.join
-
This class provides an implementation of ResetableIterator.
- ArrayListBackedIterator() - Constructor for class org.apache.hadoop.contrib.utils.join.ArrayListBackedIterator
-
- ArrayListBackedIterator(ArrayList<Object>) - Constructor for class org.apache.hadoop.contrib.utils.join.ArrayListBackedIterator
-
C
- clone(JobConf) - Method in class org.apache.hadoop.contrib.utils.join.TaggedMapOutput
-
- close() - Method in class org.apache.hadoop.contrib.utils.join.ArrayListBackedIterator
-
- close() - Method in class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
-
- close() - Method in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
-
- close() - Method in interface org.apache.hadoop.contrib.utils.join.ResetableIterator
-
- collect(Object, TaggedMapOutput, OutputCollector, Reporter) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
-
The subclass can overwrite this method to perform additional filtering
and/or other processing logic before a value is collected.
- collected - Variable in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
-
- combine(Object[], Object[]) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
-
- configure(JobConf) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
-
- configure(JobConf) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
-
- configure(JobConf) - Method in class org.apache.hadoop.contrib.utils.join.JobBase
-
Initializes a new instance from a JobConf
.
- createDataJoinJob(String[]) - Static method in class org.apache.hadoop.contrib.utils.join.DataJoinJob
-
- createResetableIterator() - Method in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
-
The subclass can provide a different implementation on ResetableIterator.
D
- DataJoinJob - Class in org.apache.hadoop.contrib.utils.join
-
This class implements the main function for creating a map/reduce
job to join data of different sources.
- DataJoinJob() - Constructor for class org.apache.hadoop.contrib.utils.join.DataJoinJob
-
- DataJoinMapperBase - Class in org.apache.hadoop.contrib.utils.join
-
This abstract class serves as the base class for the mapper class of a data
join job.
- DataJoinMapperBase() - Constructor for class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
-
- DataJoinReducerBase - Class in org.apache.hadoop.contrib.utils.join
-
This abstract class serves as the base class for the reducer class of a data
join job.
- DataJoinReducerBase() - Constructor for class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
-
G
- generateGroupKey(TaggedMapOutput) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
-
Generate a map output key.
- generateInputTag(String) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
-
Determine the source tag based on the input file name.
- generateTaggedMapOutput(Object) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
-
Generate a tagged map output value.
- getClassByName(String) - Static method in class org.apache.hadoop.contrib.utils.join.DataJoinJob
-
- getData() - Method in class org.apache.hadoop.contrib.utils.join.TaggedMapOutput
-
- getDoubleValue(Object) - Method in class org.apache.hadoop.contrib.utils.join.JobBase
-
- getLongValue(Object) - Method in class org.apache.hadoop.contrib.utils.join.JobBase
-
- getReport() - Method in class org.apache.hadoop.contrib.utils.join.JobBase
-
log the counters
- getTag() - Method in class org.apache.hadoop.contrib.utils.join.TaggedMapOutput
-
H
- hasNext() - Method in class org.apache.hadoop.contrib.utils.join.ArrayListBackedIterator
-
I
- inputFile - Variable in class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
-
- inputTag - Variable in class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
-
J
- job - Variable in class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
-
- job - Variable in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
-
- JobBase - Class in org.apache.hadoop.contrib.utils.join
-
A common base implementing some statics collecting mechanisms that are
commonly used in a typical map/reduce job.
- JobBase() - Constructor for class org.apache.hadoop.contrib.utils.join.JobBase
-
L
- largestNumOfValues - Variable in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
-
- LOG - Static variable in class org.apache.hadoop.contrib.utils.join.JobBase
-
M
- main(String[]) - Static method in class org.apache.hadoop.contrib.utils.join.DataJoinJob
-
- map(Object, Object, OutputCollector, Reporter) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
-
- map(Object, Object, OutputCollector, Reporter) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
-
N
- next() - Method in class org.apache.hadoop.contrib.utils.join.ArrayListBackedIterator
-
- NUM_OF_VALUES_FIELD - Static variable in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
-
- numOfValues - Variable in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
-
O
- org.apache.hadoop.contrib.utils.join - package org.apache.hadoop.contrib.utils.join
-
R
- reduce(Object, Iterator, OutputCollector, Reporter) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
-
- reduce(Object, Iterator, OutputCollector, Reporter) - Method in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
-
- remove() - Method in class org.apache.hadoop.contrib.utils.join.ArrayListBackedIterator
-
- report() - Method in class org.apache.hadoop.contrib.utils.join.JobBase
-
log the counters
- reporter - Variable in class org.apache.hadoop.contrib.utils.join.DataJoinMapperBase
-
- reporter - Variable in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
-
- reset() - Method in class org.apache.hadoop.contrib.utils.join.ArrayListBackedIterator
-
- reset() - Method in interface org.apache.hadoop.contrib.utils.join.ResetableIterator
-
- ResetableIterator - Interface in org.apache.hadoop.contrib.utils.join
-
This defines an iterator interface that will help the reducer class
re-group its input by source tags.
- runJob(JobConf) - Static method in class org.apache.hadoop.contrib.utils.join.DataJoinJob
-
Submit/run a map/reduce job.
S
- setDoubleValue(Object, double) - Method in class org.apache.hadoop.contrib.utils.join.JobBase
-
Set the given counter to the given value
- setLongValue(Object, long) - Method in class org.apache.hadoop.contrib.utils.join.JobBase
-
Set the given counter to the given value
- setTag(Text) - Method in class org.apache.hadoop.contrib.utils.join.TaggedMapOutput
-
- SOURCE_TAGS_FIELD - Static variable in class org.apache.hadoop.contrib.utils.join.DataJoinReducerBase
-
T
- tag - Variable in class org.apache.hadoop.contrib.utils.join.TaggedMapOutput
-
- TaggedMapOutput - Class in org.apache.hadoop.contrib.utils.join
-
This abstract class serves as the base class for the values that
flow from the mappers to the reducers in a data join job.
- TaggedMapOutput() - Constructor for class org.apache.hadoop.contrib.utils.join.TaggedMapOutput
-
A C D G H I J L M N O R S T
Copyright © 2015 Apache Software Foundation. All Rights Reserved.