public class MapRIFileInputStream
extends org.apache.hadoop.mapred.IFileInputStream
Constructor and Description |
---|
MapRIFileInputStream(InputStream in,
long len,
boolean checkLength,
org.apache.hadoop.conf.Configuration conf) |
MapRIFileInputStream(InputStream in,
long len,
org.apache.hadoop.conf.Configuration conf)
Given input stream and length of file verify the filesize and provide a way to
extract mapoutputsize.
|
Modifier and Type | Method and Description |
---|---|
MapOutputFileInfo |
getMapOutputFileInfo() |
long |
getSize() |
close, getChecksum, getPosition, read, read, readWithChecksum, skip
available, mark, markSupported, read, reset
public MapRIFileInputStream(InputStream in, long len, org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public MapRIFileInputStream(InputStream in, long len, boolean checkLength, org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public MapOutputFileInfo getMapOutputFileInfo()
public long getSize()
getSize
in class org.apache.hadoop.mapred.IFileInputStream
Copyright © 2018 Apache Software Foundation. All Rights Reserved.