org.apache.hadoop.tools.rumen

类 DefaultInputDemuxer

java.lang.Object

org.apache.hadoop.tools.rumen.DefaultInputDemuxer

所有已实现的接口:

Closeable, AutoCloseable, InputDemuxer

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.

构造器概要

构造器

构造器和说明
DefaultInputDemuxer()

方法概要

方法

限定符和类型	方法和说明
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 pair.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

DefaultInputDemuxer

public DefaultInputDemuxer()

方法详细资料

bindTo

public void bindTo(Path path,
          Configuration conf)
            throws IOException

从接口复制的说明: InputDemuxer

Bind the InputDemuxer to a particular file.

指定者:

bindTo 在接口中 InputDemuxer

参数:

path - The path to the find it should bind to.

conf - Configuration

抛出:

IOException - 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.

getNext

public org.apache.hadoop.tools.rumen.Pair<String,InputStream> getNext()
                                                               throws IOException

从接口复制的说明: InputDemuxer

Get the next pair. The name should preserve the original job history file or job conf file name. The input object should be closed before calling getNext() again. The old input object would be invalid after calling getNext() again.

指定者:

getNext 在接口中 InputDemuxer

返回:

the next pair.

抛出:

IOException

close

public void close()
           throws IOException

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

抛出:

IOException