Modifier and Type | Method and Description |
---|---|
static ChunkImpl |
ChunkImpl.getBlankChunk() |
static ChunkImpl |
ChunkImpl.read(DataInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ServletDiagnostics.sawChunk(ChunkImpl c,
int pos) |
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 |
---|---|
protected String |
ChukwaArchiveHourlyOutputFormat.generateFileNameForKeyValue(ChukwaArchiveKey key,
ChunkImpl chunk,
String name) |
protected String |
ChukwaArchiveDataTypeOutputFormat.generateFileNameForKeyValue(ChukwaArchiveKey key,
ChunkImpl chunk,
String name) |
protected String |
ChukwaArchiveDailyOutputFormat.generateFileNameForKeyValue(ChukwaArchiveKey key,
ChunkImpl chunk,
String name) |
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 |
---|---|
ChunkImpl |
ConstRateAdaptor.nextChunk(int arraySize) |
Modifier and Type | Method and Description |
---|---|
protected void |
ConstRateValidator.MapClass.map(ChukwaArchiveKey key,
ChunkImpl val,
org.apache.hadoop.mapreduce.Mapper.Context context) |
protected void |
DumpChunks.updateMatchCatalog(String streamName,
ChunkImpl chunk) |
Constructor and Description |
---|
ConstRateValidator.ByteRange(ChunkImpl val) |
Copyright © ${year} The Apache Software Foundation