public class SequenceFilesFromMailArchivesMapper
extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
Constructor and Description |
---|
SequenceFilesFromMailArchivesMapper() |
Modifier and Type | Method and Description |
---|---|
protected static String |
generateKey(String mboxFilename,
String prefix,
String messageId) |
void |
map(org.apache.hadoop.io.IntWritable key,
org.apache.hadoop.io.BytesWritable value,
org.apache.hadoop.mapreduce.Mapper.Context context) |
long |
parseMailboxLineByLine(String filename,
InputStream mailBoxInputStream,
org.apache.hadoop.mapreduce.Mapper.Context context) |
void |
setup(org.apache.hadoop.mapreduce.Mapper.Context context) |
public void setup(org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
setup
in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
IOException
InterruptedException
public long parseMailboxLineByLine(String filename, InputStream mailBoxInputStream, org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
IOException
InterruptedException
protected static String generateKey(String mboxFilename, String prefix, String messageId)
public void map(org.apache.hadoop.io.IntWritable key, org.apache.hadoop.io.BytesWritable value, org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
map
in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
IOException
InterruptedException
Copyright © 2008–2017 The Apache Software Foundation. All rights reserved.