Package org.apache.hadoop.mapred.join

Class StreamBackedIterator<X extends Writable>

java.lang.Object

org.apache.hadoop.mapreduce.lib.join.StreamBackedIterator<X>

org.apache.hadoop.mapred.join.StreamBackedIterator<X>

All Implemented Interfaces:

ResetableIterator<X>, ResetableIterator<X>

@Public
@Stable
public class StreamBackedIterator<X extends Writable>
extends StreamBackedIterator<X>
implements ResetableIterator<X>

This class provides an implementation of ResetableIterator. This implementation uses a byte array to store elements added to it.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.mapred.join.ResetableIterator

org.apache.hadoop.mapred.join.ResetableIterator.EMPTY<U extends Writable>

Nested classes/interfaces inherited from interface org.apache.hadoop.mapreduce.lib.join.ResetableIterator

org.apache.hadoop.mapreduce.lib.join.ResetableIterator.EMPTY<U extends Writable>

Constructor Summary

Constructors

Constructor	Description
StreamBackedIterator()

Method Summary

Methods inherited from class org.apache.hadoop.mapreduce.lib.join.StreamBackedIterator

add, clear, close, hasNext, next, replay, reset

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.mapreduce.lib.join.ResetableIterator

add, clear, close, hasNext, next, replay, reset

Constructor Details

StreamBackedIterator

public StreamBackedIterator()