public class HadoopShims_2_2 extends Object implements HadoopShims
HadoopShims.ByteBufferPoolShim, HadoopShims.DirectCompressionType, HadoopShims.DirectDecompressor, HadoopShims.Factory, HadoopShims.TextReaderShim, HadoopShims.ZeroCopyReaderShim
Modifier and Type | Method and Description |
---|---|
HadoopShims.DirectDecompressor |
getDirectDecompressor(HadoopShims.DirectCompressionType codec)
Get a direct decompressor codec, if it is available
|
HadoopShims.TextReaderShim |
getTextReaderShim(InputStream in)
Wrap a TextReaderShim around an input stream.
|
HadoopShims.ZeroCopyReaderShim |
getZeroCopyReader(org.apache.hadoop.fs.FSDataInputStream in,
HadoopShims.ByteBufferPoolShim pool)
Provides an HDFS ZeroCopyReader shim.
|
public HadoopShims.DirectDecompressor getDirectDecompressor(HadoopShims.DirectCompressionType codec)
HadoopShims
getDirectDecompressor
in interface HadoopShims
public HadoopShims.ZeroCopyReaderShim getZeroCopyReader(org.apache.hadoop.fs.FSDataInputStream in, HadoopShims.ByteBufferPoolShim pool) throws IOException
HadoopShims
getZeroCopyReader
in interface HadoopShims
in
- FSDataInputStream to read from (where the cached/mmap buffers are tied to)IOException
public HadoopShims.TextReaderShim getTextReaderShim(InputStream in) throws IOException
HadoopShims
getTextReaderShim
in interface HadoopShims
IOException
Copyright © 2016 The Apache Software Foundation. All rights reserved.