org.apache.hadoop.tools.rumen

接口 InputDemuxer

所有超级接口:

AutoCloseable, Closeable

所有已知实现类:

DefaultInputDemuxer

public interface InputDemuxer
extends Closeable

InputDemuxer dem-ultiplexes the input files into individual input streams.

方法概要

方法

限定符和类型	方法和说明
void	bindTo(Path path, Configuration conf) Bind the InputDemuxer to a particular file.
org.apache.hadoop.tools.rumen.Pair<String,InputStream>	getNext() Get the next pair.

从接口继承的方法 java.io.Closeable

close

方法详细资料

bindTo

void bindTo(Path path,
          Configuration conf)
            throws IOException

Bind the InputDemuxer to a particular file.

参数:

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

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

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.

返回:

the next pair.

抛出:

IOException