Constructor and Description |
---|
FSDataInputStreamWrapper(FSDataInputStream stream,
long len) |
Modifier and Type | Class and Description |
---|---|
class |
InputStreamFSInputWrapper
This class wraps an
InputStream and exposes it as FSDataInputStream . |
Modifier and Type | Field and Description |
---|---|
protected FSDataInputStream |
FileInputFormat.stream
The input stream reading from the input file.
|
Modifier and Type | Method and Description |
---|---|
protected FSDataInputStream |
FileInputFormat.decorateInputStream(FSDataInputStream inputStream,
FileInputSplit fileSplit)
This method allows to wrap/decorate the raw
FSDataInputStream for a certain file split, e.g., for decoding. |
FSDataInputStream |
FileInputFormat.InputSplitOpenThread.waitForCompletion() |
Modifier and Type | Method and Description |
---|---|
protected FSDataInputStream |
FileInputFormat.decorateInputStream(FSDataInputStream inputStream,
FileInputSplit fileSplit)
This method allows to wrap/decorate the raw
FSDataInputStream for a certain file split, e.g., for decoding. |
Constructor and Description |
---|
BlockBasedInput(FSDataInputStream in,
int blockSize) |
Modifier and Type | Method and Description |
---|---|
abstract FSDataInputStream |
FileSystem.open(Path f)
Opens an FSDataInputStream at the indicated Path.
|
abstract FSDataInputStream |
FileSystem.open(Path f,
int bufferSize)
Opens an FSDataInputStream at the indicated Path.
|
Modifier and Type | Class and Description |
---|---|
class |
LocalDataInputStream
The
LocalDataInputStream class is a wrapper class for a data
input stream to the local file system. |
Modifier and Type | Method and Description |
---|---|
FSDataInputStream |
LocalFileSystem.open(Path f) |
FSDataInputStream |
LocalFileSystem.open(Path f,
int bufferSize) |
Modifier and Type | Class and Description |
---|---|
class |
HadoopDataInputStream
Concrete implementation of the
FSDataInputStream for the
Hadoop Distributed File System. |
Modifier and Type | Method and Description |
---|---|
FSDataInputStream |
MapRFileSystem.open(Path f) |
FSDataInputStream |
MapRFileSystem.open(Path f,
int bufferSize) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.