public class SegmentReader extends Configured implements Tool, Reducer<Text,NutchWritable,Text,Text>
| Modifier and Type | Class and Description |
|---|---|
static class |
SegmentReader.InputCompatMapper |
static class |
SegmentReader.SegmentReaderStats |
static class |
SegmentReader.TextOutputFormat
Implements a text output format
|
| Constructor and Description |
|---|
SegmentReader() |
SegmentReader(Configuration conf,
boolean co,
boolean fe,
boolean ge,
boolean pa,
boolean pd,
boolean pt) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
configure(JobConf job) |
void |
dump(Path segment,
Path output) |
void |
get(Path segment,
Text key,
java.io.Writer writer,
java.util.Map<java.lang.String,java.util.List<Writable>> results) |
void |
getStats(Path segment,
SegmentReader.SegmentReaderStats stats) |
void |
list(java.util.List<Path> dirs,
java.io.Writer writer) |
static void |
main(java.lang.String[] args) |
void |
reduce(Text key,
java.util.Iterator<NutchWritable> values,
OutputCollector<Text,Text> output,
Reporter reporter) |
int |
run(java.lang.String[] args) |
getConf, setConfclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetConf, setConfpublic SegmentReader()
public SegmentReader(Configuration conf, boolean co, boolean fe, boolean ge, boolean pa, boolean pd, boolean pt)
public void configure(JobConf job)
configure in interface JobConfigurablepublic void close()
close in interface java.io.Closeableclose in interface java.lang.AutoCloseablepublic void reduce(Text key, java.util.Iterator<NutchWritable> values, OutputCollector<Text,Text> output, Reporter reporter) throws java.io.IOException
public void dump(Path segment, Path output) throws java.io.IOException
java.io.IOExceptionpublic void get(Path segment, Text key, java.io.Writer writer, java.util.Map<java.lang.String,java.util.List<Writable>> results) throws java.lang.Exception
java.lang.Exceptionpublic void list(java.util.List<Path> dirs, java.io.Writer writer) throws java.lang.Exception
java.lang.Exceptionpublic void getStats(Path segment, SegmentReader.SegmentReaderStats stats) throws java.lang.Exception
java.lang.Exceptionpublic int run(java.lang.String[] args)
throws java.lang.Exception
public static void main(java.lang.String[] args)
throws java.lang.Exception
java.lang.ExceptionCopyright © 2017 The Apache Software Foundation