org.apache.hadoop.streaming

类 StreamXmlRecordReader

java.lang.Object

org.apache.hadoop.streaming.StreamBaseRecordReader

org.apache.hadoop.streaming.StreamXmlRecordReader

所有已实现的接口:

RecordReader<Text,Text>

public class StreamXmlRecordReader
extends StreamBaseRecordReader

A way to interpret XML fragments as Mapper input records. Values are XML subtrees delimited by configurable tags. Keys could be the value of a certain attribute in the XML subtree, but this is left to the stream processor application. The name-value properties that StreamXmlRecordReader understands are: String begin (chars marking beginning of record) String end (chars marking end of record) int maxrec (maximum record size) int lookahead(maximum lookahead to sync CDATA) boolean slowmatch

字段概要

从类继承的字段 org.apache.hadoop.streaming.StreamBaseRecordReader

LOG

构造器概要

构造器

构造器和说明
StreamXmlRecordReader(FSDataInputStream in, FileSplit split, Reporter reporter, JobConf job, FileSystem fs)

方法概要

方法

限定符和类型	方法和说明
void	init()
boolean	next(Text key, Text value) Read a record.
void	seekNextRecordBoundary() Implementation should seek forward in_ to the first byte of the next record.

从类继承的方法 org.apache.hadoop.streaming.StreamBaseRecordReader

close, createKey, createValue, getPos, getProgress

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

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

构造器详细资料

StreamXmlRecordReader

public StreamXmlRecordReader(FSDataInputStream in,
                     FileSplit split,
                     Reporter reporter,
                     JobConf job,
                     FileSystem fs)
                      throws IOException

抛出:

IOException

方法详细资料

init

public void init()
          throws IOException

抛出:

IOException

next

public boolean next(Text key,
           Text value)
             throws IOException

从类复制的说明: StreamBaseRecordReader

Read a record. Implementation should call numRecStats at the end

指定者:

next 在接口中 RecordReader<Text,Text>

指定者:

next 在类中 StreamBaseRecordReader

参数:

key - the key to read data into

value - the value to read data into

返回:

true iff a key/value was read, false if at EOF

抛出:

IOException

seekNextRecordBoundary

public void seekNextRecordBoundary()
                            throws IOException

从类复制的说明: StreamBaseRecordReader

Implementation should seek forward in_ to the first byte of the next record. The initial byte offset in the stream is arbitrary.

指定者:

seekNextRecordBoundary 在类中 StreamBaseRecordReader

抛出:

IOException