Package | Description |
---|---|
org.apache.hadoop.chukwa.extraction.demux | |
org.apache.hadoop.chukwa.extraction.engine | |
org.apache.hadoop.chukwa.extraction.engine.datasource.record |
Modifier and Type | Method and Description |
---|---|
void |
TaggerPlugin.tag(String line,
Record record) |
Modifier and Type | Class and Description |
---|---|
class |
ChukwaRecord |
Modifier and Type | Method and Description |
---|---|
TreeMap<Long,List<Record>> |
SearchResult.getRecords() |
TreeMap<Long,List<Record>> |
ChukwaSearchResult.getRecords() |
Modifier and Type | Method and Description |
---|---|
static String |
RecordUtil.getClusterName(Record record) |
Modifier and Type | Method and Description |
---|---|
void |
SearchResult.setRecords(TreeMap<Long,List<Record>> records) |
void |
ChukwaSearchResult.setRecords(TreeMap<Long,List<Record>> records) |
Modifier and Type | Method and Description |
---|---|
static List<Record> |
ChukwaFileParser.readData(String cluster,
String dataSource,
int maxRows,
long t1,
long t0,
long maxOffset,
String filter,
String fileName,
org.apache.hadoop.fs.FileSystem fs) |
static List<Record> |
ChukwaSequenceFileParser.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) |
Modifier and Type | Method and Description |
---|---|
void |
ChukwaRecordDataSource.extractRecords(ChukwaDSInternalResult res,
int directoryType,
String rootFolder,
String dataSource,
String day,
String hour,
int rawIndex,
Token token,
List<Record> records,
int maxRows,
long t0,
long t1,
String filter) |
Copyright © ${year} The Apache Software Foundation