public class PortableDataStream
extends Object
implements scala.Serializable
Constructor and Description |
---|
PortableDataStream(org.apache.hadoop.mapreduce.lib.input.CombineFileSplit isplit,
org.apache.hadoop.mapreduce.TaskAttemptContext context,
Integer index) |
public PortableDataStream(org.apache.hadoop.mapreduce.lib.input.CombineFileSplit isplit, org.apache.hadoop.mapreduce.TaskAttemptContext context, Integer index)
public java.io.DataInputStream open()
public byte[] toArray()
public String getPath()