| Package | Description |
|---|---|
| org.apache.hadoop.chukwa.extraction.demux.processor.mapper |
| Class and Description |
|---|
| AbstractProcessor |
| ChunkProcessor |
| ClientTraceProcessor.Locality |
| JobLog.CounterHash
Parse counter string to object
Example string:
{(org\.apache\.hadoop\.mapred\.JobInProgress$Counter)(Job Counters )
[(TOTAL_LAUNCHED_REDUCES)(Launched reduce tasks)(1)]
[(TOTAL_LAUNCHED_MAPS)(Launched map tasks)(14)]
[(DATA_LOCAL_MAPS)(Data-local map tasks)(14)]
}
{(FileSystemCounters)(FileSystemCounters)
[(FILE_BYTES_READ)(FILE_BYTES_READ)(132)]
[(HDFS_BYTES_READ)(HDFS_BYTES_READ)(20471)]
[(FILE_BYTES_WRITTEN)(FILE_BYTES_WRITTEN)(790)]
[(HDFS_BYTES_WRITTEN)(HDFS_BYTES_WRITTEN)(248)]
}
|
| JobLog.JobLogLine |
| MapProcessor |
| Ps.InvalidPsRecord |
| UnknownRecordTypeException |
Copyright © ${year} The Apache Software Foundation