public class DefaultInputDemuxer extends Object implements InputDemuxer
DefaultInputDemuxer
acts as a pass-through demuxer. It just opens
each file and returns back the input stream. If the input is compressed, it
would return a decompression stream.Constructor and Description |
---|
DefaultInputDemuxer() |
Modifier and Type | Method and Description |
---|---|
void |
bindTo(Path path,
Configuration conf)
Bind the
InputDemuxer to a particular file. |
void |
close() |
org.apache.hadoop.tools.rumen.Pair<String,InputStream> |
getNext()
Get the next
|
public void bindTo(Path path, Configuration conf) throws IOException
InputDemuxer
InputDemuxer
to a particular file.bindTo
in interface InputDemuxer
path
- The path to the file it should bind to.conf
- ConfigurationIOException
- Returns true when the binding succeeds. If the file can be read
but is in the wrong format, returns false. IOException is
reserved for read errors.public org.apache.hadoop.tools.rumen.Pair<String,InputStream> getNext() throws IOException
InputDemuxer
getNext
in interface InputDemuxer
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2013 Apache Software Foundation. All rights reserved.