Uses of Class
org.apache.hadoop.mapreduce.lib.join.TupleWritable
Packages that use TupleWritable
-
Uses of TupleWritable in org.apache.hadoop.mapred.join
Subclasses of TupleWritable in org.apache.hadoop.mapred.join -
Uses of TupleWritable in org.apache.hadoop.mapreduce.lib.join
Methods in org.apache.hadoop.mapreduce.lib.join that return TupleWritableModifier and TypeMethodDescriptionprotected TupleWritableCompositeRecordReader.createTupleWritable()Create a value to be used internally for joins.JoinRecordReader.createValue()Methods in org.apache.hadoop.mapreduce.lib.join that return types with arguments of type TupleWritableModifier and TypeMethodDescriptionCompositeInputFormat.createRecordReader(InputSplit split, TaskAttemptContext taskContext) Construct a CompositeRecordReader for the children of this InputFormat as defined in the init expression.protected ResetableIterator<TupleWritable>JoinRecordReader.getDelegate()Return an iterator wrapping the JoinCollector.Methods in org.apache.hadoop.mapreduce.lib.join with parameters of type TupleWritableModifier and TypeMethodDescriptionprotected abstract booleanCompositeRecordReader.combine(Object[] srcs, TupleWritable value) protected booleanInnerJoinRecordReader.combine(Object[] srcs, TupleWritable dst) Return true iff the tuple is full (all data sources contain this key).protected booleanMultiFilterRecordReader.combine(Object[] srcs, TupleWritable dst) Default implementation offersMultiFilterRecordReader.emit(org.apache.hadoop.mapreduce.lib.join.TupleWritable)every Tuple from the collector (the outer join of child RRs).protected booleanOuterJoinRecordReader.combine(Object[] srcs, TupleWritable dst) Emit everything from the collector.protected abstract VMultiFilterRecordReader.emit(TupleWritable dst) For each tuple emitted, return a value (typically one of the values in the tuple).protected VOverrideRecordReader.emit(TupleWritable dst) Emit the value with the highest position in the tuple.