public class JSONRecordReader
extends org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.MapWritable>
| Constructor and Description |
|---|
JSONRecordReader() |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
boolean |
decodeLineToJson(org.apache.hadoop.io.Text line) |
org.apache.hadoop.io.Text |
getCurrentKey() |
org.apache.hadoop.io.MapWritable |
getCurrentValue() |
float |
getProgress() |
void |
initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
boolean |
nextKeyValue() |
void |
toMapWritable(org.apache.hadoop.io.Text line) |
public void initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
throws java.io.IOException
initialize in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.MapWritable>java.io.IOExceptionpublic org.apache.hadoop.io.Text getCurrentKey()
throws java.io.IOException,
java.lang.InterruptedException
getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.MapWritable>java.io.IOExceptionjava.lang.InterruptedExceptionpublic org.apache.hadoop.io.MapWritable getCurrentValue()
throws java.io.IOException,
java.lang.InterruptedException
getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.MapWritable>java.io.IOExceptionjava.lang.InterruptedExceptionpublic float getProgress()
throws java.io.IOException,
java.lang.InterruptedException
getProgress in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.MapWritable>java.io.IOExceptionjava.lang.InterruptedExceptionpublic void close()
throws java.io.IOException
close in interface java.io.Closeableclose in interface java.lang.AutoCloseableclose in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.MapWritable>java.io.IOExceptionpublic boolean nextKeyValue()
throws java.io.IOException,
java.lang.InterruptedException
nextKeyValue in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.MapWritable>java.io.IOExceptionjava.lang.InterruptedExceptionpublic boolean decodeLineToJson(org.apache.hadoop.io.Text line)
public void toMapWritable(org.apache.hadoop.io.Text line)
throws org.json.simple.parser.ParseException
org.json.simple.parser.ParseException