Uses of Class
org.apache.hadoop.mapred.join.TupleWritable
Packages that use TupleWritable
-
Uses of TupleWritable in org.apache.hadoop.mapred.join
Methods in org.apache.hadoop.mapred.join that return TupleWritableModifier and TypeMethodDescriptionprotected TupleWritableCompositeRecordReader.createInternalValue()Create a value to be used internally for joins.JoinRecordReader.createValue()Create an object of the appropriate type to be used as a value.Methods in org.apache.hadoop.mapred.join that return types with arguments of type TupleWritableModifier and TypeMethodDescriptionprotected ResetableIterator<TupleWritable>JoinRecordReader.getDelegate()Return an iterator wrapping the JoinCollector.CompositeInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter) Construct a CompositeRecordReader for the children of this InputFormat as defined in the init expression.Methods in org.apache.hadoop.mapred.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.mapred.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.booleanJoinRecordReader.next(K key, TupleWritable value) Emit the next set of key, value pairs as defined by the child RecordReaders and operation associated with this composite RR.