Package | Description |
---|---|
org.apache.hadoop.chukwa.extraction.archive | |
org.apache.hadoop.chukwa.extraction.demux | |
org.apache.hadoop.chukwa.extraction.demux.processor.mapper |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapred.RecordWriter<ChukwaArchiveKey,ChunkImpl> |
ChukwaArchiveDataTypeOutputFormat.getRecordWriter(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.mapred.JobConf job,
String name,
org.apache.hadoop.util.Progressable arg3) |
Modifier and Type | Method and Description |
---|---|
int |
ChukwaArchiveStreamNamePartitioner.getPartition(ChukwaArchiveKey key,
ChunkImpl chunk,
int numReduceTasks) |
int |
ChukwaArchiveHourlyPartitioner.getPartition(ChukwaArchiveKey key,
ChunkImpl chunl,
int numReduceTasks) |
int |
ChukwaArchiveDataTypePartitioner.getPartition(ChukwaArchiveKey key,
ChunkImpl chunk,
int numReduceTasks) |
int |
ChukwaArchiveDailyPartitioner.getPartition(ChukwaArchiveKey key,
ChunkImpl chunl,
int numReduceTasks) |
Modifier and Type | Method and Description |
---|---|
void |
Demux.MapClass.map(ChukwaArchiveKey key,
ChunkImpl chunk,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
MapProcessor.process(ChukwaArchiveKey archiveKey,
Chunk chunk,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
AbstractProcessor.process(ChukwaArchiveKey archiveKey,
Chunk chunk,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
Copyright © 2016 Apache Software Foundation. All Rights Reserved.