edu.isi.hadoop.icmptrain

Class ICMPTrainInputFormat

java.lang.Object

edu.isi.hadoop.icmptrain.ICMPTrainInputFormat

public class ICMPTrainInputFormat
extends 

This class can serve as input format (option -inputformat edu.isi.hadoop.icmptrain.ICMPTrainInputFormat to Hadoop streaming) for reading LANDER icmptrain data files. See ICMPTrainRecordReader for details.

Constructor Summary

Constructors

Constructor and Description
ICMPTrainInputFormat()

Method Summary

Methods

Modifier and Type	Method and Description
void	configure(JobConf conf)
	getRecordReader(InputSplit genericSplit, JobConf job, Reporter reporter)
protected boolean	isSplitable(FileSystem fs, Path file)

Methods inherited from class java.lang.Object

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

Constructor Detail

ICMPTrainInputFormat

public ICMPTrainInputFormat()

Method Detail

configure

public void configure(JobConf conf)

isSplitable

protected boolean isSplitable(FileSystem fs,
                  Path file)

getRecordReader

public  getRecordReader(InputSplit genericSplit,
                    JobConf job,
                    Reporter reporter)
                      throws java.io.IOException

Parameters:

genericSplit - Input split

job - Job configuration

reporter - reporter

Returns:

ICMPTrainRecordReader

Throws:

java.io.IOException - On input file/parse error