org.apache.hadoop.chukwa.extraction.engine.datasource.record

Class ChukwaSequenceFileParser

java.lang.Object

org.apache.hadoop.chukwa.extraction.engine.datasource.record.ChukwaSequenceFileParser

public class ChukwaSequenceFileParser
extends Object

Constructor Summary

Constructors

Constructor and Description
ChukwaSequenceFileParser()

Method Summary

Modifier and Type	Method and Description
protected static boolean	isValid(ChukwaRecord record, String filter)
static List<Record>	readData(String cluster, String dataSource, int maxRows, long t1, long t0, long maxOffset, String filter, String fileName, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

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

Constructor Detail

ChukwaSequenceFileParser

public ChukwaSequenceFileParser()

Method Detail

readData

public static List<Record> readData(String cluster,
                                    String dataSource,
                                    int maxRows,
                                    long t1,
                                    long t0,
                                    long maxOffset,
                                    String filter,
                                    String fileName,
                                    org.apache.hadoop.fs.FileSystem fs,
                                    org.apache.hadoop.conf.Configuration conf)
                             throws MalformedFileFormat

Throws:

MalformedFileFormat

isValid

protected static boolean isValid(ChukwaRecord record,
                                 String filter)