public class SegmentReader extends Configured implements Tool
| Modifier and Type | Class and Description |
|---|---|
static class |
SegmentReader.InputCompatMapper |
static class |
SegmentReader.InputCompatReducer |
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 |
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) |
int |
run(java.lang.String[] args) |
void |
setup(Job job) |
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 setup(Job job)
public void close()
public void dump(Path segment, Path output) throws java.io.IOException, java.lang.InterruptedException, java.lang.ClassNotFoundException
java.io.IOExceptionjava.lang.InterruptedExceptionjava.lang.ClassNotFoundExceptionpublic 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 © 2019 The Apache Software Foundation