A B C D E F G H I J K L M N O P Q R S T U V W X Y

A

AbstractMetricsContext - Class in org.apache.hadoop.metrics.spi

The main class of the Service Provider Interface.

AbstractMetricsContext() - Constructor for class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Creates a new instance of AbstractMetricsContext

AbstractProcessor - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

AbstractProcessor() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.AbstractProcessor

accept(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.chukwa.datacollection.collector.servlet.ServletCollector

activateOptions() - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

Adaptor - Interface in org.apache.hadoop.chukwa.datacollection.adaptor

An adaptor is a component that runs within the Local Agent, producing chunks of monitoring data.

adaptor - Variable in class org.apache.hadoop.chukwa.datacollection.sender.ChukwaHttpSender.CommitListEntry

ADAPTOR_NAME - Static variable in class org.apache.hadoop.chukwa.util.MaxRateSender

adaptorCount() - Method in class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

adaptorCount - Variable in class org.apache.hadoop.chukwa.datacollection.agent.metrics.AgentMetrics

AdaptorException - Exception in org.apache.hadoop.chukwa.datacollection.adaptor

AdaptorException() - Constructor for exception org.apache.hadoop.chukwa.datacollection.adaptor.AdaptorException

AdaptorException(String, Throwable) - Constructor for exception org.apache.hadoop.chukwa.datacollection.adaptor.AdaptorException

AdaptorException(String) - Constructor for exception org.apache.hadoop.chukwa.datacollection.adaptor.AdaptorException

AdaptorException(Throwable) - Constructor for exception org.apache.hadoop.chukwa.datacollection.adaptor.AdaptorException

AdaptorFactory - Class in org.apache.hadoop.chukwa.datacollection.agent

Produces new unconfigured adaptors, given the class name of the appender type

AdaptorFactory() - Constructor for class org.apache.hadoop.chukwa.datacollection.agent.AdaptorFactory

adaptorID - Variable in class org.apache.hadoop.chukwa.datacollection.adaptor.ExecAdaptor

adaptorID - Variable in class org.apache.hadoop.chukwa.datacollection.adaptor.FileAdaptor

adaptorID - Variable in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

adaptorTimestampField - Static variable in interface org.apache.hadoop.chukwa.datacollection.connector.Connector

adaptorURIField - Static variable in interface org.apache.hadoop.chukwa.datacollection.connector.Connector

add(Chunk) - Method in class org.apache.hadoop.chukwa.datacollection.agent.MemLimitQueue

add(Chunk) - Method in class org.apache.hadoop.chukwa.datacollection.agent.WaitingQueue

add(List<Chunk>) - Method in class org.apache.hadoop.chukwa.datacollection.agent.WaitingQueue

add(Chunk) - Method in interface org.apache.hadoop.chukwa.datacollection.ChunkQueue

Add a chunk to the queue, blocking if queue is full.

add(Chunk) - Method in interface org.apache.hadoop.chukwa.datacollection.ChunkReceiver

Add a chunk to the queue, potentially blocking.

add(String, String, String, long) - Method in class org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController

Registers a new adaptor.

add(String, String, String, long, long, long) - Method in class org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController

Registers a new adaptor.

add(URL) - Method in class org.apache.hadoop.chukwa.datacollection.sender.RetryListOfCollectors

add(List<Chunk>) - Method in interface org.apache.hadoop.chukwa.datacollection.writer.ChukwaWriter

add(Chunk) - Method in class org.apache.hadoop.chukwa.datacollection.writer.ConsoleWriter

add(List<Chunk>) - Method in class org.apache.hadoop.chukwa.datacollection.writer.ConsoleWriter

add(List<Chunk>) - Method in class org.apache.hadoop.chukwa.datacollection.writer.Dedup

add(Chunk) - Method in class org.apache.hadoop.chukwa.datacollection.writer.InMemoryWriter

add(List<Chunk>) - Method in class org.apache.hadoop.chukwa.datacollection.writer.InMemoryWriter

add(List<Chunk>) - Method in class org.apache.hadoop.chukwa.datacollection.writer.PipelineStageWriter

add(List<Chunk>) - Method in class org.apache.hadoop.chukwa.datacollection.writer.SeqFileWriter

add(Chunk) - Method in class org.apache.hadoop.chukwa.datacollection.writer.SeqFileWriter

add(String, String) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecord

add(String, String) - Method in interface org.apache.hadoop.chukwa.extraction.engine.Record

ADD_UUID_PROPERTY - Static variable in class org.apache.hadoop.chukwa.inputtools.log4j.Log4JMetricsContext

addDefaultTag(String) - Method in class org.apache.hadoop.chukwa.datacollection.DataFactory

addedAdaptor - Variable in class org.apache.hadoop.chukwa.datacollection.agent.metrics.AgentMetrics

addedChunk - Variable in class org.apache.hadoop.chukwa.datacollection.agent.metrics.ChunkQueueMetrics

addFile(String, String, long, long) - Method in class org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController

Registers a new "LineFileTailUTF8" adaptor and starts it at offset 0.

addFile(String, String) - Method in class org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController

addMetrics(T) - Method in class org.apache.hadoop.chukwa.inputtools.jplugin.ChukwaMetricsList

addRecord(byte[]) - Method in class org.apache.hadoop.chukwa.ChunkBuilder

Adds the data in rec to an internal buffer; rec can be reused immediately.

addStatus(String, String) - Method in class org.apache.hadoop.chukwa.inputtools.jplugin.JPluginStatusMetricsList

addTag(String) - Method in interface org.apache.hadoop.chukwa.Chunk

Add tag.

addTag(String) - Method in class org.apache.hadoop.chukwa.ChunkImpl

addToHash(JSONObject, String[], JSONObject) - Method in class org.apache.hadoop.chukwa.hicc.Workspace

agent - Variable in class org.apache.hadoop.chukwa.datacollection.agent.AgentControlSocketListener

AgentActivityMBean - Class in org.apache.hadoop.chukwa.datacollection.agent.metrics

AgentActivityMBean(MetricsRegistry, String) - Constructor for class org.apache.hadoop.chukwa.datacollection.agent.metrics.AgentActivityMBean

AgentControlSocketListener - Class in org.apache.hadoop.chukwa.datacollection.agent

Class to handle the agent control protocol.

AgentControlSocketListener(ChukwaAgent) - Constructor for class org.apache.hadoop.chukwa.datacollection.agent.AgentControlSocketListener

Initializes listener, but does not bind to socket.

AgentMetrics - Class in org.apache.hadoop.chukwa.datacollection.agent.metrics

AgentMetrics(String, String) - Constructor for class org.apache.hadoop.chukwa.datacollection.agent.metrics.AgentMetrics

Creates a new instance of AgentMetrics

agentMetrics - Static variable in class org.apache.hadoop.chukwa.datacollection.agent.metrics.AgentMetrics

Aggregator - Class in org.apache.hadoop.chukwa.database

Aggregator() - Constructor for class org.apache.hadoop.chukwa.database.Aggregator

applicationField - Static variable in interface org.apache.hadoop.chukwa.extraction.engine.Record

AreaCalculator - Class in org.apache.hadoop.chukwa.hicc

AreaCalculator() - Constructor for class org.apache.hadoop.chukwa.hicc.AreaCalculator

B

bailout(int) - Static method in class org.apache.hadoop.chukwa.util.DaemonWatcher

bodyField - Static variable in interface org.apache.hadoop.chukwa.extraction.engine.Record

BUFFER_SIZE - Static variable in class org.apache.hadoop.chukwa.util.MaxRateSender

buildDailyFiles(String, String, String, int) - Static method in class org.apache.hadoop.chukwa.extraction.demux.DailyChukwaRecordRolling

buildFileName(int, String, String, int, String, String, int) - Method in class org.apache.hadoop.chukwa.extraction.engine.datasource.record.ChukwaRecordDataSource

buildGenericRecord(ChukwaRecord, String, long, String) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.AbstractProcessor

buildHourlyFiles(String, String, String, int, int) - Static method in class org.apache.hadoop.chukwa.extraction.demux.HourlyChukwaRecordRolling

C

CENTURY - Static variable in class org.apache.hadoop.chukwa.database.DatabaseConfig

changeViewInfo(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.chukwa.hicc.Workspace

CharFileTailingAdaptorUTF8 - Class in org.apache.hadoop.chukwa.datacollection.adaptor.filetailer

A subclass of FileTailingAdaptor that reads UTF8/ascii files and splits records at carriage returns.

CharFileTailingAdaptorUTF8() - Constructor for class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.CharFileTailingAdaptorUTF8

CharFileTailingAdaptorUTF8NewLineEscaped - Class in org.apache.hadoop.chukwa.datacollection.adaptor.filetailer

A subclass of FileTailingAdaptor that reads UTF8/ascii files and splits records at non-escaped carriage returns

CharFileTailingAdaptorUTF8NewLineEscaped() - Constructor for class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.CharFileTailingAdaptorUTF8NewLineEscaped

CharFileTailUTF8 - Static variable in class org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController

CharFileTailUTF8NewLineEscaped - Static variable in class org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController

Chart - Class in org.apache.hadoop.chukwa.hicc

Chart(HttpServletRequest) - Constructor for class org.apache.hadoop.chukwa.hicc.Chart

checkDemuxInputDir(String) - Method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

Test if demuxInputDir exists

checkDemuxOutputDir(String) - Method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

Test if demuxOutputDir exists

checkEntryConditions() - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

Fix for late-initialisation

CHUKWA_ARCHIVE_DIR_FIELD - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

CHUKWA_CONSTANT - Interface in org.apache.hadoop.chukwa.extraction

CHUKWA_DATA_SINK_DIR_FIELD - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

CHUKWA_DEMUX_REDUCER_COUNT_FIELD - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

CHUKWA_NAGIOS_HOST_FIELD - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

CHUKWA_NAGIOS_PORT_FIELD - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

CHUKWA_POST_PROCESS_DIR_FIELD - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

CHUKWA_REPORTING_HOST_FIELD - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

CHUKWA_ROOT_DIR_FIELD - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

CHUKWA_ROOT_REPOS_DIR_FIELD - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

ChukwaAgent - Class in org.apache.hadoop.chukwa.datacollection.agent

The local agent daemon that runs on each machine.

ChukwaAgent() - Constructor for class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

ChukwaAgent(Configuration) - Constructor for class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

ChukwaAgent.AlreadyRunningException - Exception in org.apache.hadoop.chukwa.datacollection.agent

ChukwaAgent.AlreadyRunningException() - Constructor for exception org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent.AlreadyRunningException

ChukwaAgentController - Class in org.apache.hadoop.chukwa.datacollection.controller

A convenience library for applications to communicate to the ChukwaAgent.

ChukwaAgentController() - Constructor for class org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController

ChukwaAgentController(String, int) - Constructor for class org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController

ChukwaAgentController.AddAdaptorTask - Class in org.apache.hadoop.chukwa.datacollection.controller

ChukwaArchiveBuilder - Class in org.apache.hadoop.chukwa.extraction.archive

ChukwaArchiveBuilder() - Constructor for class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveBuilder

ChukwaArchiveDailyOutputFormat - Class in org.apache.hadoop.chukwa.extraction.archive

ChukwaArchiveDailyOutputFormat() - Constructor for class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveDailyOutputFormat

ChukwaArchiveDailyPartitioner<K,V> - Class in org.apache.hadoop.chukwa.extraction.archive

ChukwaArchiveDailyPartitioner() - Constructor for class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveDailyPartitioner

ChukwaArchiveDataTypeOutputFormat - Class in org.apache.hadoop.chukwa.extraction.archive

ChukwaArchiveDataTypeOutputFormat() - Constructor for class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveDataTypeOutputFormat

ChukwaArchiveDataTypePartitioner<K,V> - Class in org.apache.hadoop.chukwa.extraction.archive

ChukwaArchiveDataTypePartitioner() - Constructor for class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveDataTypePartitioner

ChukwaArchiveHourlyOutputFormat - Class in org.apache.hadoop.chukwa.extraction.archive

ChukwaArchiveHourlyOutputFormat() - Constructor for class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveHourlyOutputFormat

ChukwaArchiveHourlyPartitioner<K,V> - Class in org.apache.hadoop.chukwa.extraction.archive

ChukwaArchiveHourlyPartitioner() - Constructor for class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveHourlyPartitioner

ChukwaArchiveKey - Class in org.apache.hadoop.chukwa

ChukwaArchiveKey() - Constructor for class org.apache.hadoop.chukwa.ChukwaArchiveKey

ChukwaArchiveKey(long, String, String, long) - Constructor for class org.apache.hadoop.chukwa.ChukwaArchiveKey

ChukwaArchiveKey.Comparator - Class in org.apache.hadoop.chukwa

ChukwaArchiveKey.Comparator() - Constructor for class org.apache.hadoop.chukwa.ChukwaArchiveKey.Comparator

ChukwaArchiveManager - Class in org.apache.hadoop.chukwa.extraction.archive

ChukwaArchiveManager() - Constructor for class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveManager

ChukwaArchiveManager(ChukwaConfiguration) - Constructor for class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveManager

ChukwaArchiveMerger - Class in org.apache.hadoop.chukwa.extraction.archive

ChukwaArchiveMerger() - Constructor for class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveMerger

ChukwaArchiveStreamNameOutputFormat - Class in org.apache.hadoop.chukwa.extraction.archive

ChukwaArchiveStreamNameOutputFormat() - Constructor for class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveStreamNameOutputFormat

ChukwaArchiveStreamNamePartitioner<K,V> - Class in org.apache.hadoop.chukwa.extraction.archive

ChukwaArchiveStreamNamePartitioner() - Constructor for class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveStreamNamePartitioner

ChukwaConfiguration - Class in org.apache.hadoop.chukwa.conf

ChukwaConfiguration() - Constructor for class org.apache.hadoop.chukwa.conf.ChukwaConfiguration

ChukwaConfiguration(boolean) - Constructor for class org.apache.hadoop.chukwa.conf.ChukwaConfiguration

ChukwaDailyRollingFileAppender - Class in org.apache.hadoop.chukwa.inputtools.log4j

ChukwaDailyRollingFileAppender is a slightly modified version of DailyRollingFileAppender, with modified versions of its subAppend() and rollOver() functions.

ChukwaDailyRollingFileAppender() - Constructor for class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

The default constructor does nothing.

ChukwaDailyRollingFileAppender(Layout, String, String) - Constructor for class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

Instantiate a DailyRollingFileAppender and open the file designated by filename.

ChukwaDSInternalResult - Class in org.apache.hadoop.chukwa.extraction.engine.datasource.record

ChukwaDSInternalResult() - Constructor for class org.apache.hadoop.chukwa.extraction.engine.datasource.record.ChukwaDSInternalResult

ChukwaFileParser - Class in org.apache.hadoop.chukwa.extraction.engine.datasource.record

ChukwaFileParser() - Constructor for class org.apache.hadoop.chukwa.extraction.engine.datasource.record.ChukwaFileParser

ChukwaHttpSender - Class in org.apache.hadoop.chukwa.datacollection.sender

Encapsulates all of the http setup and connection details needed for chunks to be delivered to a collector.

ChukwaHttpSender(Configuration) - Constructor for class org.apache.hadoop.chukwa.datacollection.sender.ChukwaHttpSender

ChukwaHttpSender.CommitListEntry - Class in org.apache.hadoop.chukwa.datacollection.sender

ChukwaHttpSender.CommitListEntry(Adaptor, long) - Constructor for class org.apache.hadoop.chukwa.datacollection.sender.ChukwaHttpSender.CommitListEntry

ChukwaInputFormat - Class in org.apache.hadoop.chukwa.inputtools

An InputFormat for processing logfiles in Chukwa.

ChukwaInputFormat() - Constructor for class org.apache.hadoop.chukwa.inputtools.ChukwaInputFormat

ChukwaInputFormat.ChukwaRecordReader - Class in org.apache.hadoop.chukwa.inputtools

ChukwaInputFormat.ChukwaRecordReader(Configuration, FileSplit) - Constructor for class org.apache.hadoop.chukwa.inputtools.ChukwaInputFormat.ChukwaRecordReader

ChukwaMetrics - Interface in org.apache.hadoop.chukwa.inputtools.jplugin

ChukwaMetricsList<T extends ChukwaMetrics> - Class in org.apache.hadoop.chukwa.inputtools.jplugin

ChukwaMetricsList() - Constructor for class org.apache.hadoop.chukwa.inputtools.jplugin.ChukwaMetricsList

ChukwaMetricsList(String) - Constructor for class org.apache.hadoop.chukwa.inputtools.jplugin.ChukwaMetricsList

ChukwaOutputCollector - Class in org.apache.hadoop.chukwa.extraction.demux.processor

ChukwaOutputCollector(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.ChukwaOutputCollector

ChukwaRecord - Class in org.apache.hadoop.chukwa.extraction.engine

ChukwaRecord() - Constructor for class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecord

ChukwaRecordDataSource - Class in org.apache.hadoop.chukwa.extraction.engine.datasource.record

ChukwaRecordDataSource() - Constructor for class org.apache.hadoop.chukwa.extraction.engine.datasource.record.ChukwaRecordDataSource

ChukwaRecordJT - Class in org.apache.hadoop.chukwa.extraction.engine

ChukwaRecordJT() - Constructor for class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT

ChukwaRecordJT(long, TreeMap<String, Buffer>) - Constructor for class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT

ChukwaRecordJT.Comparator - Class in org.apache.hadoop.chukwa.extraction.engine

ChukwaRecordJT.Comparator() - Constructor for class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT.Comparator

ChukwaRecordKey - Class in org.apache.hadoop.chukwa.extraction.engine

ChukwaRecordKey() - Constructor for class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey

ChukwaRecordKey(String, String) - Constructor for class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey

ChukwaRecordKey.Comparator - Class in org.apache.hadoop.chukwa.extraction.engine

ChukwaRecordKey.Comparator() - Constructor for class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey.Comparator

ChukwaRecordOutputFormat - Class in org.apache.hadoop.chukwa.extraction.demux

ChukwaRecordOutputFormat() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.ChukwaRecordOutputFormat

ChukwaRecordPartitioner<K,V> - Class in org.apache.hadoop.chukwa.extraction.demux

ChukwaRecordPartitioner() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.ChukwaRecordPartitioner

ChukwaSearchResult - Class in org.apache.hadoop.chukwa.extraction.engine

ChukwaSearchResult() - Constructor for class org.apache.hadoop.chukwa.extraction.engine.ChukwaSearchResult

ChukwaSearchService - Class in org.apache.hadoop.chukwa.extraction.engine

ChukwaSearchService() - Constructor for class org.apache.hadoop.chukwa.extraction.engine.ChukwaSearchService

ChukwaSender - Interface in org.apache.hadoop.chukwa.datacollection.sender

ChukwaSequenceFileParser - Class in org.apache.hadoop.chukwa.extraction.engine.datasource.record

ChukwaSequenceFileParser() - Constructor for class org.apache.hadoop.chukwa.extraction.engine.datasource.record.ChukwaSequenceFileParser

ChukwaTTInstru - Class in org.apache.hadoop.chukwa.inputtools

An instrumentation plugin for Hadoop, to trigger Chukwa-based task logfile collection.

ChukwaTTInstru(TaskTracker) - Constructor for class org.apache.hadoop.chukwa.inputtools.ChukwaTTInstru

ChukwaWriter - Interface in org.apache.hadoop.chukwa.datacollection.writer

Chunk - Interface in org.apache.hadoop.chukwa

A chunk is a sequence of bytes at a particular logical offset in a stream, and containing one or more "records".

ChunkBuilder - Class in org.apache.hadoop.chukwa

Right now, just handles record collection.

ChunkBuilder() - Constructor for class org.apache.hadoop.chukwa.ChunkBuilder

chunkDataField - Static variable in interface org.apache.hadoop.chukwa.extraction.engine.Record

chunkExceptionField - Static variable in interface org.apache.hadoop.chukwa.extraction.engine.Record

ChunkImpl - Class in org.apache.hadoop.chukwa

ChunkImpl(String, String, long, byte[], Adaptor) - Constructor for class org.apache.hadoop.chukwa.ChunkImpl

ChunkProcessor - Interface in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

ChunkQueue - Interface in org.apache.hadoop.chukwa.datacollection

A generic interface for queues of Chunks.

ChunkQueueActivityMBean - Class in org.apache.hadoop.chukwa.datacollection.agent.metrics

ChunkQueueActivityMBean(MetricsRegistry, String) - Constructor for class org.apache.hadoop.chukwa.datacollection.agent.metrics.ChunkQueueActivityMBean

ChunkQueueMetrics - Class in org.apache.hadoop.chukwa.datacollection.agent.metrics

ChunkQueueMetrics(String, String) - Constructor for class org.apache.hadoop.chukwa.datacollection.agent.metrics.ChunkQueueMetrics

Creates a new instance of QueueMetrics

ChunkReceiver - Interface in org.apache.hadoop.chukwa.datacollection

ChunkSaver - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

ChunkSaver() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.ChunkSaver

classField - Static variable in interface org.apache.hadoop.chukwa.extraction.engine.Record

clean() - Method in class org.apache.hadoop.chukwa.inputtools.mdl.LoaderServer

clean() - Method in class org.apache.hadoop.chukwa.util.PidFile

cleanUp() - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

ClientAck - Class in org.apache.hadoop.chukwa.datacollection.writer

ClientAck() - Constructor for class org.apache.hadoop.chukwa.datacollection.writer.ClientAck

ClientTrace - Class in org.apache.hadoop.chukwa.extraction.demux.processor.reducer

ClientTrace() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.reducer.ClientTrace

ClientTraceProcessor - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

ClientTraceProcessor() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.ClientTraceProcessor

ClientTraceProcessor.Locality - Enum in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

clone() - Method in class org.apache.hadoop.chukwa.ChukwaArchiveKey

clone() - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT

clone() - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey

cloneView(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.chukwa.hicc.Workspace

close() - Method in interface org.apache.hadoop.chukwa.datacollection.writer.ChukwaWriter

close() - Method in class org.apache.hadoop.chukwa.datacollection.writer.ConsoleWriter

close() - Method in class org.apache.hadoop.chukwa.datacollection.writer.Dedup

close() - Method in class org.apache.hadoop.chukwa.datacollection.writer.InMemoryWriter

close() - Method in class org.apache.hadoop.chukwa.datacollection.writer.PipelineStageWriter

close() - Method in class org.apache.hadoop.chukwa.datacollection.writer.SeqFileWriter

close() - Method in class org.apache.hadoop.chukwa.inputtools.ChukwaInputFormat.ChukwaRecordReader

close() - Method in class org.apache.hadoop.chukwa.util.DatabaseWriter

close() - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Stops monitoring and frees buffered data, returning this object to its initial state.

ClusterConfig - Class in org.apache.hadoop.chukwa.hicc

ClusterConfig() - Constructor for class org.apache.hadoop.chukwa.hicc.ClusterConfig

ClusterConfig - Class in org.apache.hadoop.chukwa.util

ClusterConfig() - Constructor for class org.apache.hadoop.chukwa.util.ClusterConfig

clusterMap - Static variable in class org.apache.hadoop.chukwa.hicc.ClusterConfig

clusterMap - Static variable in class org.apache.hadoop.chukwa.util.ClusterConfig

collect(List<Chunk>, int) - Method in class org.apache.hadoop.chukwa.datacollection.agent.MemLimitQueue

collect(List<Chunk>, int) - Method in class org.apache.hadoop.chukwa.datacollection.agent.WaitingQueue

collect(List<Chunk>, int) - Method in interface org.apache.hadoop.chukwa.datacollection.ChunkQueue

Return at least one, and no more than count, Chunks into chunks.

collect(ChukwaRecordKey, ChukwaRecord) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.ChukwaOutputCollector

collectorRollover - Variable in class org.apache.hadoop.chukwa.datacollection.sender.metrics.HttpSenderMetrics

collectors - Variable in class org.apache.hadoop.chukwa.datacollection.sender.ChukwaHttpSender

CollectorStub - Class in org.apache.hadoop.chukwa.datacollection.collector

CollectorStub() - Constructor for class org.apache.hadoop.chukwa.datacollection.collector.CollectorStub

ColorPicker - Class in org.apache.hadoop.chukwa.hicc

ColorPicker() - Constructor for class org.apache.hadoop.chukwa.hicc.ColorPicker

compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.chukwa.ChukwaArchiveKey.Comparator

compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT.Comparator

compare(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey.Comparator

compareRaw(byte[], int, int, byte[], int, int) - Static method in class org.apache.hadoop.chukwa.ChukwaArchiveKey.Comparator

compareRaw(byte[], int, int, byte[], int, int) - Static method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT.Comparator

compareRaw(byte[], int, int, byte[], int, int) - Static method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey.Comparator

compareTo(Object) - Method in class org.apache.hadoop.chukwa.ChukwaArchiveKey

compareTo(Object) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT

compareTo(Object) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey

computeMacro(String) - Method in class org.apache.hadoop.chukwa.database.Macro

conf - Static variable in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

conf - Variable in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveManager

conf - Variable in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

conf - Variable in class org.apache.hadoop.chukwa.extraction.demux.PostProcessorManager

Config - Class in org.apache.hadoop.chukwa.hicc

Config() - Constructor for class org.apache.hadoop.chukwa.hicc.Config

configure(JobConf) - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveDailyPartitioner

configure(JobConf) - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveDataTypePartitioner

configure(JobConf) - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveHourlyPartitioner

configure(JobConf) - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveStreamNamePartitioner

configure(JobConf) - Method in class org.apache.hadoop.chukwa.extraction.demux.ChukwaRecordPartitioner

configure(JobConf) - Method in class org.apache.hadoop.chukwa.extraction.demux.Demux.MapClass

Connector - Interface in org.apache.hadoop.chukwa.datacollection.connector

This class is responsible for setting up a long living process that repeatedly calls the send function of a Sender.

connectorClient - Variable in class org.apache.hadoop.chukwa.datacollection.connector.http.HttpConnector

ConsoleOutConnector - Class in org.apache.hadoop.chukwa.datacollection.test

Output events to stdout.

ConsoleOutConnector(ChukwaAgent) - Constructor for class org.apache.hadoop.chukwa.datacollection.test.ConsoleOutConnector

ConsoleOutConnector(ChukwaAgent, boolean) - Constructor for class org.apache.hadoop.chukwa.datacollection.test.ConsoleOutConnector

ConsoleWriter - Class in org.apache.hadoop.chukwa.datacollection.writer

ConsoleWriter() - Constructor for class org.apache.hadoop.chukwa.datacollection.writer.ConsoleWriter

ConsoleWriter(boolean) - Constructor for class org.apache.hadoop.chukwa.datacollection.writer.ConsoleWriter

Consolidator - Class in org.apache.hadoop.chukwa.database

Consolidator(String, String) - Constructor for class org.apache.hadoop.chukwa.database.Consolidator

ConstRateAdaptor - Class in org.apache.hadoop.chukwa.util

ConstRateAdaptor() - Constructor for class org.apache.hadoop.chukwa.util.ConstRateAdaptor

containsField(String) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecord

containsRotateFlag(int, String, String, String, String) - Method in class org.apache.hadoop.chukwa.extraction.engine.datasource.record.ChukwaRecordDataSource

convertObjectsToViewList(JSONObject[]) - Method in class org.apache.hadoop.chukwa.hicc.Workspace

convertObjectsToWidgetList(JSONObject[]) - Method in class org.apache.hadoop.chukwa.hicc.Workspace

createInstance(String) - Static method in class org.apache.hadoop.chukwa.util.DaemonWatcher

createKey() - Method in class org.apache.hadoop.chukwa.inputtools.ChukwaInputFormat.ChukwaRecordReader

createRecord(String) - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Creates a new AbstractMetricsRecord instance with the given recordName.

createTables() - Method in class org.apache.hadoop.chukwa.database.TableCreator

createTables(long, long) - Method in class org.apache.hadoop.chukwa.database.TableCreator

createValue() - Method in class org.apache.hadoop.chukwa.inputtools.ChukwaInputFormat.ChukwaRecordReader

D

DaemonWatcher - Class in org.apache.hadoop.chukwa.util

DailyChukwaRecordRolling - Class in org.apache.hadoop.chukwa.extraction.demux

DailyChukwaRecordRolling() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.DailyChukwaRecordRolling

DatabaseConfig - Class in org.apache.hadoop.chukwa.database

DatabaseConfig(String) - Constructor for class org.apache.hadoop.chukwa.database.DatabaseConfig

DatabaseConfig() - Constructor for class org.apache.hadoop.chukwa.database.DatabaseConfig

DatabaseDS - Class in org.apache.hadoop.chukwa.extraction.engine.datasource.database

DatabaseDS() - Constructor for class org.apache.hadoop.chukwa.extraction.engine.datasource.database.DatabaseDS

DatabaseLoader - Class in org.apache.hadoop.chukwa.extraction.database

DatabaseLoader() - Constructor for class org.apache.hadoop.chukwa.extraction.database.DatabaseLoader

DatabaseWriter - Class in org.apache.hadoop.chukwa.util

DatabaseWriter(String, String, String) - Constructor for class org.apache.hadoop.chukwa.util.DatabaseWriter

DatabaseWriter(String) - Constructor for class org.apache.hadoop.chukwa.util.DatabaseWriter

DataConfig - Class in org.apache.hadoop.chukwa.inputtools.mdl

DataConfig(String) - Constructor for class org.apache.hadoop.chukwa.inputtools.mdl.DataConfig

DataConfig() - Constructor for class org.apache.hadoop.chukwa.inputtools.mdl.DataConfig

DataExpiration - Class in org.apache.hadoop.chukwa.database

DataExpiration() - Constructor for class org.apache.hadoop.chukwa.database.DataExpiration

dataFactory - Variable in class org.apache.hadoop.chukwa.ChunkImpl

DataFactory - Class in org.apache.hadoop.chukwa.datacollection

DatasetMapper - Class in org.apache.hadoop.chukwa.hicc

DatasetMapper(String) - Constructor for class org.apache.hadoop.chukwa.hicc.DatasetMapper

dataSize - Variable in class org.apache.hadoop.chukwa.datacollection.agent.metrics.ChunkQueueMetrics

DataSource - Interface in org.apache.hadoop.chukwa.extraction.engine.datasource

DataSourceException - Exception in org.apache.hadoop.chukwa.extraction.engine.datasource

DataSourceException() - Constructor for exception org.apache.hadoop.chukwa.extraction.engine.datasource.DataSourceException

DataSourceException(String) - Constructor for exception org.apache.hadoop.chukwa.extraction.engine.datasource.DataSourceException

DataSourceException(Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.engine.datasource.DataSourceException

DataSourceException(String, Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.engine.datasource.DataSourceException

DataSourceFactory - Class in org.apache.hadoop.chukwa.extraction.engine.datasource

dataSources - Static variable in class org.apache.hadoop.chukwa.extraction.demux.PostProcessorManager

DAY - Static variable in class org.apache.hadoop.chukwa.database.DatabaseConfig

dayTextFormat - Variable in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

DBException - Exception in org.apache.hadoop.chukwa.extraction.database

DBException() - Constructor for exception org.apache.hadoop.chukwa.extraction.database.DBException

DBException(String) - Constructor for exception org.apache.hadoop.chukwa.extraction.database.DBException

DBException(Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.database.DBException

DBException(String, Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.database.DBException

DBPlugin - Interface in org.apache.hadoop.chukwa.extraction.database

DebugOutputProcessor - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

DebugOutputProcessor() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.DebugOutputProcessor

DECADE - Static variable in class org.apache.hadoop.chukwa.database.DatabaseConfig

Dedup - Class in org.apache.hadoop.chukwa.datacollection.writer

Dedup() - Constructor for class org.apache.hadoop.chukwa.datacollection.writer.Dedup

DEFAULT_ARCHIVES_IN_ERROR_DIR_NAME - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

DEFAULT_ARCHIVES_MR_INPUT_DIR_NAME - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

DEFAULT_ARCHIVES_MR_OUTPUT_DIR_NAME - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

DEFAULT_ARCHIVES_PROCESSING_DIR_NAME - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

DEFAULT_CHUKWA_DATASINK_DIR_NAME - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

DEFAULT_CHUKWA_LOGS_DIR_NAME - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

DEFAULT_CHUKWA_POSTPROCESS_DIR_NAME - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

DEFAULT_DEMUX_IN_ERROR_DIR_NAME - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

DEFAULT_DEMUX_MR_INPUT_DIR_NAME - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

DEFAULT_DEMUX_MR_OUTPUT_DIR_NAME - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

DEFAULT_DEMUX_PROCESSING_DIR_NAME - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

DEFAULT_DEMUX_ROOT_DIR_NAME - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

DEFAULT_FIELD_SEPARATOR - Static variable in class org.apache.hadoop.chukwa.util.RecordConstants

DEFAULT_FINAL_ARCHIVES - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

DEFAULT_MAX_FILES_PER_DEMUX - Variable in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

DEFAULT_MAX_READ_SIZE - Static variable in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

This is the maximum amount we'll read from any one file before moving on to the next.

DEFAULT_RECORD_SEPARATOR - Static variable in class org.apache.hadoop.chukwa.util.RecordConstants

DEFAULT_REDUCER_COUNT - Variable in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

DEFAULT_REPOS_DIR_NAME - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

DefaultProcessor - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

DefaultProcessor() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.DefaultProcessor

deleteDemuxOutputDir(String) - Method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

Delete DemuxOutput directory

deleteDirectory(String) - Method in class org.apache.hadoop.chukwa.extraction.demux.PostProcessorManager

deleteView(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.chukwa.hicc.Workspace

Demux - Class in org.apache.hadoop.chukwa.extraction.demux

Demux() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.Demux

Demux.MapClass - Class in org.apache.hadoop.chukwa.extraction.demux

Demux.MapClass() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.Demux.MapClass

Demux.ReduceClass - Class in org.apache.hadoop.chukwa.extraction.demux

Demux.ReduceClass() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.Demux.ReduceClass

DemuxManager - Class in org.apache.hadoop.chukwa.extraction.demux

DemuxManager() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

DemuxManager(ChukwaConfiguration) - Constructor for class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

demuxReducerCount - Variable in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

deserialize(RecordInput, String) - Method in class org.apache.hadoop.chukwa.ChukwaArchiveKey

deserialize(RecordInput, String) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT

deserialize(RecordInput, String) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey

dest - Variable in class org.apache.hadoop.chukwa.datacollection.adaptor.FileAdaptor

destroy() - Method in class org.apache.hadoop.chukwa.datacollection.collector.servlet.ServletCollector

Df - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

Df() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Df

DFInvalidRecord - Exception in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

DFInvalidRecord() - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.DFInvalidRecord

DFInvalidRecord(String) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.DFInvalidRecord

DFInvalidRecord(Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.DFInvalidRecord

DFInvalidRecord(String, Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.DFInvalidRecord

dirExists(String) - Method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

Check if source exists and if source is a directory

doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.chukwa.datacollection.collector.servlet.ServletCollector

doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.chukwa.hicc.Iframe

doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.chukwa.hicc.Workspace

doneWithPost() - Method in class org.apache.hadoop.chukwa.datacollection.collector.servlet.ServletDiagnostics

doPost(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.chukwa.datacollection.collector.servlet.ServletCollector

doPost(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.chukwa.hicc.Iframe

doPost(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.chukwa.hicc.Workspace

doTag() - Method in class org.apache.hadoop.chukwa.hicc.ViewsTag

doUpdates(MetricsContext) - Method in class org.apache.hadoop.chukwa.datacollection.agent.metrics.AgentMetrics

Since this object is a registered updater, this method will be called periodically, e.g.

doUpdates(MetricsContext) - Method in class org.apache.hadoop.chukwa.datacollection.agent.metrics.ChunkQueueMetrics

Since this object is a registered updater, this method will be called periodically, e.g.

doUpdates(MetricsContext) - Method in class org.apache.hadoop.chukwa.datacollection.sender.metrics.HttpSenderMetrics

Since this object is a registered updater, this method will be called periodically, e.g.

DriverManagerUtil - Class in org.apache.hadoop.chukwa.util

DriverManagerUtil() - Constructor for class org.apache.hadoop.chukwa.util.DriverManagerUtil

DriverManagerUtil.ConnectionInfo - Class in org.apache.hadoop.chukwa.util

DriverManagerUtil.ConnectionInfo(String) - Constructor for class org.apache.hadoop.chukwa.util.DriverManagerUtil.ConnectionInfo

dropTables(long, long) - Method in class org.apache.hadoop.chukwa.database.DataExpiration

DsDirectory - Class in org.apache.hadoop.chukwa.extraction.engine.datasource

DumpArchive - Class in org.apache.hadoop.chukwa.util

DumpArchive() - Constructor for class org.apache.hadoop.chukwa.util.DumpArchive

DumpDataType - Class in org.apache.hadoop.chukwa.util

DumpDataType() - Constructor for class org.apache.hadoop.chukwa.util.DumpDataType

DumpRecord - Class in org.apache.hadoop.chukwa.util

DumpRecord() - Constructor for class org.apache.hadoop.chukwa.util.DumpRecord

DuplicateProcessorException - Exception in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

DuplicateProcessorException() - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.DuplicateProcessorException

DuplicateProcessorException(String) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.DuplicateProcessorException

DuplicateProcessorException(Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.DuplicateProcessorException

DuplicateProcessorException(String, Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.DuplicateProcessorException

DuplicateReduceProcessorException - Exception in org.apache.hadoop.chukwa.extraction.demux.processor.reducer

DuplicateReduceProcessorException() - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.reducer.DuplicateReduceProcessorException

DuplicateReduceProcessorException(String) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.reducer.DuplicateReduceProcessorException

DuplicateReduceProcessorException(Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.reducer.DuplicateReduceProcessorException

DuplicateReduceProcessorException(String, Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.reducer.DuplicateReduceProcessorException

E

emitRecord(String, String, OutputRecord) - Method in class org.apache.hadoop.chukwa.inputtools.log4j.Log4JMetricsContext

emitRecord(String, String, OutputRecord) - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Sends a record to the metrics system.

Employee - Class in org.apache.hadoop.chukwa.inputtools.hdfsusage

Employee() - Constructor for class org.apache.hadoop.chukwa.inputtools.hdfsusage.Employee

ENABLE_ROTATION - Static variable in class org.apache.hadoop.chukwa.datacollection.writer.SeqFileWriter

equals(Object) - Method in class org.apache.hadoop.chukwa.ChukwaArchiveKey

equals(Object) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT

equals(Object) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey

ERROR_SLEEP_TIME - Variable in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

ERROR_SLEEP_TIME - Variable in class org.apache.hadoop.chukwa.extraction.demux.PostProcessorManager

errorCount - Static variable in class org.apache.hadoop.chukwa.extraction.demux.PostProcessorManager

ErStreamHandler - Class in org.apache.hadoop.chukwa.inputtools.mdl

ErStreamHandler(InputStream, String, boolean) - Constructor for class org.apache.hadoop.chukwa.inputtools.mdl.ErStreamHandler

escapeAllButLastRecordSeparator(String, String) - Static method in class org.apache.hadoop.chukwa.util.RecordConstants

Insert the default chukwa escape sequence in record before all occurances of recordSeparator except the final one if the final record separator occurs at the end of the record

escapeAllRecordSeparators(String, String) - Static method in class org.apache.hadoop.chukwa.util.RecordConstants

Insert the default chukwa escape sequence in record before all occurances of recordSeparator.

escapeQuotes(String) - Static method in class org.apache.hadoop.chukwa.extraction.database.MetricDataLoader

ExceptionUtil - Class in org.apache.hadoop.chukwa.util

ExceptionUtil() - Constructor for class org.apache.hadoop.chukwa.util.ExceptionUtil

Exec - Class in org.apache.hadoop.chukwa.inputtools.plugin.metrics

Exec(String[]) - Constructor for class org.apache.hadoop.chukwa.inputtools.plugin.metrics.Exec

ExecAdaptor - Class in org.apache.hadoop.chukwa.datacollection.adaptor

Runs a command inside chukwa.

ExecAdaptor() - Constructor for class org.apache.hadoop.chukwa.datacollection.adaptor.ExecAdaptor

ExecHelper - Class in org.apache.hadoop.chukwa.inputtools.plugin.metrics

ExecHelper(String[]) - Constructor for class org.apache.hadoop.chukwa.inputtools.plugin.metrics.ExecHelper

ExecPlugin - Class in org.apache.hadoop.chukwa.inputtools.plugin

Runs external command-line tools, captures output.

ExecPlugin() - Constructor for class org.apache.hadoop.chukwa.inputtools.plugin.ExecPlugin

execute(String, boolean, boolean, String) - Method in class org.apache.hadoop.chukwa.hicc.DatasetMapper

execute() - Method in class org.apache.hadoop.chukwa.inputtools.plugin.ExecPlugin

execute() - Method in interface org.apache.hadoop.chukwa.inputtools.plugin.IPlugin

execute(String) - Method in class org.apache.hadoop.chukwa.util.DatabaseWriter

exist(int, String, String, String, String, String) - Method in class org.apache.hadoop.chukwa.extraction.engine.datasource.record.ChukwaRecordDataSource

extractCounters(ChukwaRecord, String) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLogHistoryProcessor

extractCounters(ChukwaRecord, String) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Log4jJobHistoryProcessor

extractRecords(ChunkReceiver, long, byte[], long) - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.FileAdaptor

Extract records from a byte sequence

extractRecords(ChunkReceiver, long, byte[]) - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.CharFileTailingAdaptorUTF8

Note: this method uses a temporary ArrayList (shared across instances).

extractRecords(ChunkReceiver, long, byte[]) - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.CharFileTailingAdaptorUTF8NewLineEscaped

Note: this method uses a temporary ArrayList (shared across instances).

extractRecords(ChunkReceiver, long, byte[]) - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

Extract records from a byte sequence

extractRecords(ChukwaDSInternalResult, int, String, String, String, String, int, Token, List<Record>, int, long, long, String) - Method in class org.apache.hadoop.chukwa.extraction.engine.datasource.record.ChukwaRecordDataSource

F

FileAdaptor - Class in org.apache.hadoop.chukwa.datacollection.adaptor

File Adaptor push small size file in one chunk to collector

FileAdaptor() - Constructor for class org.apache.hadoop.chukwa.datacollection.adaptor.FileAdaptor

fileReadOffset - Variable in class org.apache.hadoop.chukwa.datacollection.adaptor.FileAdaptor

fileReadOffset - Variable in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

next PHYSICAL offset to read

FileTailerStressTest - Class in org.apache.hadoop.chukwa.datacollection.test

FileTailerStressTest() - Constructor for class org.apache.hadoop.chukwa.datacollection.test.FileTailerStressTest

FileTailingAdaptor - Class in org.apache.hadoop.chukwa.datacollection.adaptor.filetailer

An adaptor that repeatedly tails a specified file, sending the new bytes.

FileTailingAdaptor() - Constructor for class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

filter(String) - Method in class org.apache.hadoop.chukwa.util.XssFilter

findMacros(String) - Method in class org.apache.hadoop.chukwa.database.Macro

findTableName(String, long, long) - Method in class org.apache.hadoop.chukwa.database.DatabaseConfig

findTableNameForCharts(String, long, long) - Method in class org.apache.hadoop.chukwa.database.DatabaseConfig

flat() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLog.CounterHash

Flat the counter hashs and add into map passed int.

flush() - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Called each period after all records have been emitted, this method does nothing.

format(LoggingEvent) - Method in class org.apache.hadoop.chukwa.inputtools.log4j.OneLineLogLayout

formatAdaptorStatus(Adaptor) - Method in class org.apache.hadoop.chukwa.datacollection.agent.AgentControlSocketListener

formatTimeStamp(long) - Static method in class org.apache.hadoop.chukwa.util.DatabaseWriter

fromXml(String) - Method in class org.apache.hadoop.chukwa.inputtools.jplugin.GenericChukwaMetricsList

fs - Variable in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveManager

fs - Variable in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

fs - Variable in class org.apache.hadoop.chukwa.extraction.demux.PostProcessorManager

fullQueue - Variable in class org.apache.hadoop.chukwa.datacollection.agent.metrics.ChunkQueueMetrics

G

generateFileNameForKeyValue(ChukwaArchiveKey, ChunkImpl, String) - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveDailyOutputFormat

generateFileNameForKeyValue(ChukwaArchiveKey, ChunkImpl, String) - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveDataTypeOutputFormat

generateFileNameForKeyValue(ChukwaArchiveKey, ChunkImpl, String) - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveHourlyOutputFormat

generateFileNameForKeyValue(ChukwaRecordKey, ChukwaRecord, String) - Method in class org.apache.hadoop.chukwa.extraction.demux.ChukwaRecordOutputFormat

generateLeafFileName(String) - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveStreamNameOutputFormat

generateTimeOutput(long) - Static method in class org.apache.hadoop.chukwa.extraction.demux.processor.Util

GenericChukwaMetricsList - Class in org.apache.hadoop.chukwa.inputtools.jplugin

GenericChukwaMetricsList() - Constructor for class org.apache.hadoop.chukwa.inputtools.jplugin.GenericChukwaMetricsList

GenericChukwaMetricsList(String) - Constructor for class org.apache.hadoop.chukwa.inputtools.jplugin.GenericChukwaMetricsList

GenericChukwaMetricsList.GenericChukwaMetrics - Class in org.apache.hadoop.chukwa.inputtools.jplugin

GenericChukwaMetricsList.GenericChukwaMetrics() - Constructor for class org.apache.hadoop.chukwa.inputtools.jplugin.GenericChukwaMetricsList.GenericChukwaMetrics

get(String) - Method in class org.apache.hadoop.chukwa.database.DatabaseConfig

get(int) - Method in class org.apache.hadoop.chukwa.hicc.ColorPicker

get(String) - Method in interface org.apache.hadoop.chukwa.inputtools.hdfsusage.OrgChart

get(String) - Method in class org.apache.hadoop.chukwa.inputtools.mdl.DataConfig

getAdaptorList() - Method in class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

getAgent() - Static method in class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

getApplication() - Method in interface org.apache.hadoop.chukwa.Chunk

getApplication() - Method in class org.apache.hadoop.chukwa.ChunkImpl

getArea(TreeMap<String, Double>) - Static method in class org.apache.hadoop.chukwa.hicc.AreaCalculator

getArea(double, double, double, double) - Static method in class org.apache.hadoop.chukwa.hicc.AreaCalculator

getAreas(TreeMap<String, TreeMap<String, Double>>) - Static method in class org.apache.hadoop.chukwa.hicc.AreaCalculator

getAttempts() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLog.JobLogLine

getAttribute(String) - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Convenience method for subclasses to access factory attributes.

getAttributes() - Method in class org.apache.hadoop.chukwa.inputtools.hdfsusage.HDFSUsageMetrics

getAttributes() - Method in interface org.apache.hadoop.chukwa.inputtools.jplugin.ChukwaMetrics

getAttributes() - Method in class org.apache.hadoop.chukwa.inputtools.jplugin.GenericChukwaMetricsList.GenericChukwaMetrics

getAttributeTable(String) - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Returns an attribute-value map derived from the factory attributes by finding all factory attributes that begin with contextName.tableName.

getBlankChunk() - Static method in class org.apache.hadoop.chukwa.ChunkImpl

getBody() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.LogEntry

getChukwaClientHostname() - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

getChukwaClientPortNum() - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

getChunk() - Method in class org.apache.hadoop.chukwa.ChunkBuilder

getClassName() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.LogEntry

getCleanUpRegex() - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

getClusterName(Record) - Static method in class org.apache.hadoop.chukwa.extraction.engine.RecordUtil

getClusters() - Method in class org.apache.hadoop.chukwa.hicc.ClusterConfig

getClusters() - Method in class org.apache.hadoop.chukwa.util.ClusterConfig

getCmde() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.ExecAdaptor

getCmde() - Method in class org.apache.hadoop.chukwa.inputtools.plugin.ExecPlugin

getCmde() - Method in class org.apache.hadoop.chukwa.inputtools.plugin.metrics.Exec

getCmde() - Method in class org.apache.hadoop.chukwa.inputtools.plugin.metrics.ExecHelper

getCmde() - Method in class org.apache.hadoop.chukwa.inputtools.plugin.nodeactivity.NodeActivityPlugin

getCmde() - Method in class org.apache.hadoop.chukwa.inputtools.plugin.pbsnode.PbsNodePlugin

getCollectorURLs() - Method in class org.apache.hadoop.chukwa.datacollection.DataFactory

getConfiguration() - Method in class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

getConnection() - Method in class org.apache.hadoop.chukwa.util.DatabaseWriter

getConnection(String) - Static method in class org.apache.hadoop.chukwa.util.DriverManagerUtil

getConnector() - Method in class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

getContents(File) - Static method in class org.apache.hadoop.chukwa.database.Aggregator

getContents(File) - Static method in class org.apache.hadoop.chukwa.hicc.ClusterConfig

getContents(String) - Static method in class org.apache.hadoop.chukwa.hicc.JSONLoader

getContents(File) - Static method in class org.apache.hadoop.chukwa.hicc.Views

getContents(File) - Static method in class org.apache.hadoop.chukwa.hicc.Workspace

getContents(File) - Static method in class org.apache.hadoop.chukwa.util.ClusterConfig

getContextFactory() - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Returns the factory by which this context was created.

getContextName() - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Returns the context name.

getControllerPort() - Method in class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

getCounterHash() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLog.JobLogLine

getCurrentStatus() - Method in interface org.apache.hadoop.chukwa.datacollection.adaptor.Adaptor

Return the adaptor's state Should not include class name, datatype or byte offset, which are written by caller.

getCurrentStatus() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.ExecAdaptor

getCurrentStatus() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.FileAdaptor

getCurrentStatus() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

getCurrentStatus() - Method in class org.apache.hadoop.chukwa.util.ConstRateAdaptor

getCurrentStatus() - Method in class org.apache.hadoop.chukwa.util.MaxRateSender

getData() - Method in interface org.apache.hadoop.chukwa.Chunk

getData() - Method in class org.apache.hadoop.chukwa.ChunkImpl

getDataset() - Method in class org.apache.hadoop.chukwa.hicc.DatasetMapper

getDataSource(String) - Method in class org.apache.hadoop.chukwa.extraction.engine.datasource.DataSourceFactory

getDataType() - Method in class org.apache.hadoop.chukwa.ChukwaArchiveKey

getDataType() - Method in interface org.apache.hadoop.chukwa.Chunk

getDataType() - Method in class org.apache.hadoop.chukwa.ChunkImpl

getDataType() - Method in interface org.apache.hadoop.chukwa.extraction.demux.processor.mapper.ChunkProcessor

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.ClientTraceProcessor

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.DebugOutputProcessor

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.HadoopLogProcessor

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.HadoopMetricsProcessor

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Iostat

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobConfProcessor

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLogHistoryProcessor

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Log4jJobHistoryProcessor

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.PbsNodes

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Sar

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.SysLog

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Top

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Torque

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.YWatch

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.reducer.ClientTrace

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.reducer.IdentityReducer

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.reducer.JobLogHistoryReduceProcessor

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.reducer.MRJobReduceProcessor

getDataType() - Method in interface org.apache.hadoop.chukwa.extraction.demux.processor.reducer.ReduceProcessor

getDataType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.reducer.SystemMetrics

getDate() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.LogEntry

getDatePattern() - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

Returns the value of the DatePattern option.

getDebugInfo() - Method in class org.apache.hadoop.chukwa.ChunkImpl

getDefaultTags() - Method in class org.apache.hadoop.chukwa.datacollection.DataFactory

getDescription(int) - Method in class org.apache.hadoop.chukwa.hicc.Views

getEndDate(String) - Method in class org.apache.hadoop.chukwa.hicc.TimeHandler

getEndDate() - Method in class org.apache.hadoop.chukwa.hicc.TimeHandler

getEndHour() - Method in class org.apache.hadoop.chukwa.hicc.TimeHandler

getEndMinute() - Method in class org.apache.hadoop.chukwa.hicc.TimeHandler

getEndTime() - Method in class org.apache.hadoop.chukwa.hicc.TimeHandler

getEndTimeText() - Method in class org.apache.hadoop.chukwa.hicc.TimeHandler

getEventQueue() - Method in class org.apache.hadoop.chukwa.datacollection.DataFactory

getException() - Method in class org.apache.hadoop.chukwa.datacollection.writer.ClientAck

getFields() - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecord

getFields() - Method in interface org.apache.hadoop.chukwa.extraction.engine.Record

getId() - Method in class org.apache.hadoop.chukwa.inputtools.hdfsusage.Employee

getInitiator() - Method in interface org.apache.hadoop.chukwa.Chunk

Retrieve a reference to the adaptor that sent this event.

getInitiator() - Method in class org.apache.hadoop.chukwa.ChunkImpl

getInstance() - Static method in class org.apache.hadoop.chukwa.datacollection.DataFactory

getInstance() - Static method in class org.apache.hadoop.chukwa.extraction.engine.datasource.DataSourceFactory

getInstance() - Static method in class org.apache.hadoop.chukwa.extraction.engine.datasource.DsDirectory

getInstance() - Static method in class org.apache.hadoop.chukwa.util.DaemonWatcher

getJobId() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLog.JobLogLine

getJobLogLine(String) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLog

Job logs could be split into multiple lines.

getKey() - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey

getKey(int) - Method in class org.apache.hadoop.chukwa.hicc.Views

getKey() - Method in class org.apache.hadoop.chukwa.inputtools.hdfsusage.HDFSUsageMetrics

getKey() - Method in interface org.apache.hadoop.chukwa.inputtools.jplugin.ChukwaMetrics

getKey() - Method in class org.apache.hadoop.chukwa.inputtools.jplugin.GenericChukwaMetricsList.GenericChukwaMetrics

getLabel() - Method in enum org.apache.hadoop.chukwa.extraction.demux.processor.mapper.ClientTraceProcessor.Locality

getLastModified() - Method in class org.apache.hadoop.chukwa.inputtools.hdfsusage.HDFSUsageMetrics

getLocality(String, String) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.ClientTraceProcessor

getLogLevel() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.LogEntry

getLogType() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLog.JobLogLine

getManager() - Method in class org.apache.hadoop.chukwa.inputtools.hdfsusage.Employee

getMapFields() - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT

getMaxBackupIndex() - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

getMetrics() - Method in class org.apache.hadoop.chukwa.inputtools.hdfsusage.HDFSUsagePlugin

getMetrics() - Method in interface org.apache.hadoop.chukwa.inputtools.jplugin.JPlugin

getMetricsList() - Method in class org.apache.hadoop.chukwa.inputtools.jplugin.ChukwaMetricsList

getName() - Method in class org.apache.hadoop.chukwa.inputtools.hdfsusage.HDFSUsageMetrics

getOffset(Adaptor) - Method in class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

Returns the last offset at which a given adaptor was checkpointed

getOwner(int) - Method in class org.apache.hadoop.chukwa.hicc.Views

getParameter(String) - Method in class org.apache.hadoop.chukwa.util.XssFilter

getParameterValues(String) - Method in class org.apache.hadoop.chukwa.util.XssFilter

getPartition(ChukwaArchiveKey, ChunkImpl, int) - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveDailyPartitioner

getPartition(ChukwaArchiveKey, ChunkImpl, int) - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveDataTypePartitioner

getPartition(ChukwaArchiveKey, ChunkImpl, int) - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveHourlyPartitioner

getPartition(ChukwaArchiveKey, ChunkImpl, int) - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveStreamNamePartitioner

getPartition(ChukwaRecordKey, ChukwaRecord, int) - Method in class org.apache.hadoop.chukwa.extraction.demux.ChukwaRecordPartitioner

getPeriod() - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Returns the timer period.

getPermission(int) - Method in class org.apache.hadoop.chukwa.hicc.Views

getPort() - Method in class org.apache.hadoop.chukwa.datacollection.agent.AgentControlSocketListener

getPos() - Method in class org.apache.hadoop.chukwa.inputtools.ChukwaInputFormat.ChukwaRecordReader

getProcessList() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Ps.PsOutput

getProcessor(String) - Static method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.MapProcessorFactory

getProcessor(String) - Static method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.ProcessorFactory

getProcessor(String) - Static method in class org.apache.hadoop.chukwa.extraction.demux.processor.reducer.ReduceProcessorFactory

getProgress() - Method in class org.apache.hadoop.chukwa.inputtools.ChukwaInputFormat.ChukwaRecordReader

getProperties() - Method in class org.apache.hadoop.chukwa.util.DriverManagerUtil.ConnectionInfo

getProtocolVersion() - Method in class org.apache.hadoop.chukwa.ChunkImpl

getRandomCollector() - Method in class org.apache.hadoop.chukwa.datacollection.sender.RetryListOfCollectors

getReadPermission(int, String) - Method in class org.apache.hadoop.chukwa.hicc.Views

getRecordOffsets() - Method in interface org.apache.hadoop.chukwa.Chunk

get/set the end offsets of records in the buffer.

getRecordOffsets() - Method in class org.apache.hadoop.chukwa.ChunkImpl

getRecordReader(InputSplit, JobConf, Reporter) - Method in class org.apache.hadoop.chukwa.inputtools.ChukwaInputFormat

getRecords() - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaSearchResult

getRecords() - Method in interface org.apache.hadoop.chukwa.extraction.engine.SearchResult

getRecordType() - Method in class org.apache.hadoop.chukwa.inputtools.hdfsusage.HDFSUsagePlugin

getRecordType() - Method in class org.apache.hadoop.chukwa.inputtools.jplugin.ChukwaMetricsList

getRecordType() - Method in interface org.apache.hadoop.chukwa.inputtools.jplugin.JPlugin

getRecordType() - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

getReduceType() - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey

getReprocess() - Method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

getSeqId() - Method in class org.apache.hadoop.chukwa.ChukwaArchiveKey

getSeqID() - Method in interface org.apache.hadoop.chukwa.Chunk

getSeqID() - Method in class org.apache.hadoop.chukwa.ChunkImpl

getSerializedSizeEstimate() - Method in interface org.apache.hadoop.chukwa.Chunk

Estimate the size of this Chunk on the wire, assuming each char of metadata takes two bytes to serialize.

getSerializedSizeEstimate() - Method in class org.apache.hadoop.chukwa.ChunkImpl

getServletInfo() - Method in class org.apache.hadoop.chukwa.datacollection.collector.servlet.ServletCollector

getSize() - Method in class org.apache.hadoop.chukwa.inputtools.hdfsusage.HDFSUsageMetrics

getSource() - Method in interface org.apache.hadoop.chukwa.Chunk

getSource() - Method in class org.apache.hadoop.chukwa.ChunkImpl

getStackTrace(Throwable) - Static method in class org.apache.hadoop.chukwa.util.ExceptionUtil

getStartDate(String) - Method in class org.apache.hadoop.chukwa.hicc.TimeHandler

getStartDate() - Method in class org.apache.hadoop.chukwa.hicc.TimeHandler

getStartHour() - Method in class org.apache.hadoop.chukwa.hicc.TimeHandler

getStartMinute() - Method in class org.apache.hadoop.chukwa.hicc.TimeHandler

getStartTime() - Method in class org.apache.hadoop.chukwa.hicc.TimeHandler

getStartTimeText() - Method in class org.apache.hadoop.chukwa.hicc.TimeHandler

getStatus() - Method in class org.apache.hadoop.chukwa.datacollection.writer.ClientAck

getStatus() - Method in class org.apache.hadoop.chukwa.inputtools.hdfsusage.HDFSUsagePlugin

getStatus() - Method in interface org.apache.hadoop.chukwa.inputtools.jplugin.JPlugin

getStreamName() - Method in class org.apache.hadoop.chukwa.ChukwaArchiveKey

getStreamName() - Method in interface org.apache.hadoop.chukwa.Chunk

Get the name of the stream that this Chunk is a chunk of

getStreamName() - Method in class org.apache.hadoop.chukwa.ChunkImpl

getStreamName() - Method in interface org.apache.hadoop.chukwa.datacollection.adaptor.Adaptor

Return the stream name

getStreamName() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.ExecAdaptor

getStreamName() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.FileAdaptor

getStreamName() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

getStreamName() - Method in class org.apache.hadoop.chukwa.util.ConstRateAdaptor

getStreamName() - Method in class org.apache.hadoop.chukwa.util.MaxRateSender

getTags() - Method in interface org.apache.hadoop.chukwa.Chunk

getTags() - Method in class org.apache.hadoop.chukwa.ChunkImpl

getTags(int) - Method in class org.apache.hadoop.chukwa.hicc.JSONLoader

getTaskId() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLog.JobLogLine

getTime() - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT

getTime() - Method in interface org.apache.hadoop.chukwa.extraction.engine.Record

getTimeOut() - Method in class org.apache.hadoop.chukwa.datacollection.writer.ClientAck

getTimePartition() - Method in class org.apache.hadoop.chukwa.ChukwaArchiveKey

getTimestamp() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLog.JobLogLine

getTimestamp() - Method in class org.apache.hadoop.chukwa.inputtools.jplugin.ChukwaMetricsList

getToken() - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaSearchResult

getToken() - Method in interface org.apache.hadoop.chukwa.extraction.engine.SearchResult

getTS(int) - Method in class org.apache.hadoop.chukwa.hicc.JSONLoader

getType() - Method in interface org.apache.hadoop.chukwa.datacollection.adaptor.Adaptor

getType() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.ExecAdaptor

getType() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.FileAdaptor

getType() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

getType() - Method in class org.apache.hadoop.chukwa.util.ConstRateAdaptor

getType() - Method in class org.apache.hadoop.chukwa.util.MaxRateSender

getTypeInfo() - Static method in class org.apache.hadoop.chukwa.ChukwaArchiveKey

getTypeInfo() - Static method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT

getTypeInfo() - Static method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey

getUri() - Method in class org.apache.hadoop.chukwa.util.DriverManagerUtil.ConnectionInfo

getURL(String) - Method in class org.apache.hadoop.chukwa.hicc.ClusterConfig

getURL(String) - Method in class org.apache.hadoop.chukwa.util.ClusterConfig

getValue(String) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecord

getValue(String) - Method in interface org.apache.hadoop.chukwa.extraction.engine.Record

getValue(int) - Method in class org.apache.hadoop.chukwa.hicc.JSONLoader

getView(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.chukwa.hicc.Workspace

getViewsList(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.chukwa.hicc.Workspace

getWidgetList(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.chukwa.hicc.Workspace

getWritePermission(int, String) - Method in class org.apache.hadoop.chukwa.hicc.Views

getXAxisMap() - Method in class org.apache.hadoop.chukwa.hicc.DatasetMapper

GRACEFUL_PERIOD - Static variable in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

H

HadoopLogProcessor - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

HadoopLogProcessor() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.HadoopLogProcessor

HadoopMetricsProcessor - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

HadoopMetricsProcessor() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.HadoopMetricsProcessor

hardStop() - Method in interface org.apache.hadoop.chukwa.datacollection.adaptor.Adaptor

Signals this adaptor to come to an abrupt stop, as quickly as it can.

hardStop() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.ExecAdaptor

hardStop() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.FileAdaptor

Stop tailing the file, effective immediately.

hardStop() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

Stop tailing the file, effective immediately.

hardStop() - Method in class org.apache.hadoop.chukwa.util.ConstRateAdaptor

hardStop() - Method in class org.apache.hadoop.chukwa.util.MaxRateSender

hashCode() - Method in class org.apache.hadoop.chukwa.ChukwaArchiveKey

hashCode() - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT

hashCode() - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey

hasMore - Variable in class org.apache.hadoop.chukwa.extraction.engine.Token

hasNext() - Method in class org.apache.hadoop.chukwa.datacollection.sender.RetryListOfCollectors

hasNext() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.AbstractProcessor

HDFSUsageMetrics - Class in org.apache.hadoop.chukwa.inputtools.hdfsusage

HDFSUsageMetrics() - Constructor for class org.apache.hadoop.chukwa.inputtools.hdfsusage.HDFSUsageMetrics

HDFSUsageMetricsList - Class in org.apache.hadoop.chukwa.inputtools.hdfsusage

HDFSUsageMetricsList() - Constructor for class org.apache.hadoop.chukwa.inputtools.hdfsusage.HDFSUsageMetricsList

HDFSUsagePlugin - Class in org.apache.hadoop.chukwa.inputtools.hdfsusage

HDFSUsagePlugin() - Constructor for class org.apache.hadoop.chukwa.inputtools.hdfsusage.HDFSUsagePlugin

HourlyChukwaRecordRolling - Class in org.apache.hadoop.chukwa.extraction.demux

HourlyChukwaRecordRolling() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.HourlyChukwaRecordRolling

hourlyRolling(String) - Static method in class org.apache.hadoop.chukwa.extraction.demux.DailyChukwaRecordRolling

HttpConnector - Class in org.apache.hadoop.chukwa.datacollection.connector.http

HttpConnector(ChukwaAgent) - Constructor for class org.apache.hadoop.chukwa.datacollection.connector.http.HttpConnector

HttpConnector(ChukwaAgent, String) - Constructor for class org.apache.hadoop.chukwa.datacollection.connector.http.HttpConnector

httpException - Variable in class org.apache.hadoop.chukwa.datacollection.sender.metrics.HttpSenderMetrics

httpPost - Variable in class org.apache.hadoop.chukwa.datacollection.sender.metrics.HttpSenderMetrics

HttpSenderActivityMBean - Class in org.apache.hadoop.chukwa.datacollection.sender.metrics

HttpSenderActivityMBean(MetricsRegistry, String) - Constructor for class org.apache.hadoop.chukwa.datacollection.sender.metrics.HttpSenderActivityMBean

HttpSenderMetrics - Class in org.apache.hadoop.chukwa.datacollection.sender.metrics

HttpSenderMetrics(String, String) - Constructor for class org.apache.hadoop.chukwa.datacollection.sender.metrics.HttpSenderMetrics

Creates a new instance of HttpSenderMetrics

httpThrowable - Variable in class org.apache.hadoop.chukwa.datacollection.sender.metrics.HttpSenderMetrics

httpTimeOutException - Variable in class org.apache.hadoop.chukwa.datacollection.sender.metrics.HttpSenderMetrics

I

IdentityReducer - Class in org.apache.hadoop.chukwa.extraction.demux.processor.reducer

IdentityReducer() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.reducer.IdentityReducer

Iframe - Class in org.apache.hadoop.chukwa.hicc

Iframe() - Constructor for class org.apache.hadoop.chukwa.hicc.Iframe

ignoresThrowable() - Method in class org.apache.hadoop.chukwa.inputtools.log4j.OneLineLogLayout

init(ServletConfig) - Method in class org.apache.hadoop.chukwa.datacollection.collector.servlet.ServletCollector

init(Configuration) - Method in interface org.apache.hadoop.chukwa.datacollection.writer.ChukwaWriter

init(Configuration) - Method in class org.apache.hadoop.chukwa.datacollection.writer.ConsoleWriter

init(Configuration) - Method in class org.apache.hadoop.chukwa.datacollection.writer.Dedup

init(Configuration) - Method in class org.apache.hadoop.chukwa.datacollection.writer.InMemoryWriter

init(Configuration) - Method in class org.apache.hadoop.chukwa.datacollection.writer.PipelineStageWriter

init(Configuration) - Method in class org.apache.hadoop.chukwa.datacollection.writer.SeqFileWriter

init() - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveManager

init() - Method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

init() - Method in class org.apache.hadoop.chukwa.extraction.demux.PostProcessorManager

init(HttpServletRequest) - Method in class org.apache.hadoop.chukwa.hicc.TimeHandler

init(String[]) - Method in class org.apache.hadoop.chukwa.inputtools.hdfsusage.HDFSUsagePlugin

init(String[]) - Method in interface org.apache.hadoop.chukwa.inputtools.jplugin.JPlugin

init(String, ContextFactory) - Method in class org.apache.hadoop.chukwa.inputtools.log4j.Log4JMetricsContext

init() - Method in class org.apache.hadoop.chukwa.inputtools.mdl.LoaderServer

init() - Method in class org.apache.hadoop.chukwa.util.PidFile

init(String, ContextFactory) - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Initializes the context.

InMemoryWriter - Class in org.apache.hadoop.chukwa.datacollection.writer

InMemoryWriter() - Constructor for class org.apache.hadoop.chukwa.datacollection.writer.InMemoryWriter

interrupt() - Method in class org.apache.hadoop.chukwa.extraction.database.MetricDataLoader

Iostat - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

Iostat() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Iostat

IPlugin - Interface in org.apache.hadoop.chukwa.inputtools.plugin

isBound() - Method in class org.apache.hadoop.chukwa.datacollection.agent.AgentControlSocketListener

isFilePaused(String, String) - Method in class org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController

isMonitoring() - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Returns true if monitoring is currently in progress.

isRunning - Variable in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveManager

isRunning - Variable in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

isRunning - Variable in class org.apache.hadoop.chukwa.extraction.demux.PostProcessorManager

isThreadSafe() - Method in class org.apache.hadoop.chukwa.extraction.engine.datasource.database.DatabaseDS

isThreadSafe() - Method in interface org.apache.hadoop.chukwa.extraction.engine.datasource.DataSource

isThreadSafe() - Method in class org.apache.hadoop.chukwa.extraction.engine.datasource.record.ChukwaRecordDataSource

isThreadSafe() - Method in class org.apache.hadoop.chukwa.extraction.engine.datasource.record.RecordDS

isValid(ChukwaRecord, String) - Method in class org.apache.hadoop.chukwa.extraction.engine.datasource.record.ChukwaRecordDataSource

isValid(ChukwaRecord, String) - Static method in class org.apache.hadoop.chukwa.extraction.engine.datasource.record.ChukwaSequenceFileParser

iterator() - Method in class org.apache.hadoop.chukwa.database.DatabaseConfig

iterator() - Method in class org.apache.hadoop.chukwa.inputtools.mdl.DataConfig

J

jettyServer - Static variable in class org.apache.hadoop.chukwa.datacollection.collector.CollectorStub

JobConfProcessor - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

JobConfProcessor() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobConfProcessor

JobLog - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

JobLog() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLog

JobLog.CounterHash - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

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.CounterHash(String) - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLog.CounterHash

JobLog.JobLogLine - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

JobLog.JobLogLine(String) - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLog.JobLogLine

example lines: Task TASKID="task_200903062215_0577_r_000000" TASK_TYPE="REDUCE" START_TIME="1236386538540" SPLITS="" .

JobLogHistoryProcessor - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

JobLogHistoryProcessor() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLogHistoryProcessor

JobLogHistoryReduceProcessor - Class in org.apache.hadoop.chukwa.extraction.demux.processor.reducer

JobLogHistoryReduceProcessor() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.reducer.JobLogHistoryReduceProcessor

JPlugin<T extends ChukwaMetrics> - Interface in org.apache.hadoop.chukwa.inputtools.jplugin

JPluginAgent - Class in org.apache.hadoop.chukwa.inputtools.jplugin

JPluginAgent() - Constructor for class org.apache.hadoop.chukwa.inputtools.jplugin.JPluginAgent

JPluginMapper - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

JPluginMapper() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JPluginMapper

JPluginStatusMetricsList - Class in org.apache.hadoop.chukwa.inputtools.jplugin

JPluginStatusMetricsList(String) - Constructor for class org.apache.hadoop.chukwa.inputtools.jplugin.JPluginStatusMetricsList

jsonData - Variable in class org.apache.hadoop.chukwa.hicc.JSONLoader

JSONLoader - Class in org.apache.hadoop.chukwa.hicc

JSONLoader(String) - Constructor for class org.apache.hadoop.chukwa.hicc.JSONLoader

K

key - Variable in class org.apache.hadoop.chukwa.extraction.engine.Token

KO - Static variable in class org.apache.hadoop.chukwa.datacollection.writer.ClientAck

KO_LOCK - Static variable in class org.apache.hadoop.chukwa.datacollection.writer.ClientAck

L

length() - Method in class org.apache.hadoop.chukwa.hicc.JSONLoader

length() - Method in class org.apache.hadoop.chukwa.hicc.Views

list(String) - Method in class org.apache.hadoop.chukwa.extraction.engine.datasource.DsDirectory

loadData(FileSystem, String, HashMap<String, String>) - Static method in class org.apache.hadoop.chukwa.extraction.database.DatabaseLoader

loadDriver() - Static method in class org.apache.hadoop.chukwa.util.DriverManagerUtil

LoaderServer - Class in org.apache.hadoop.chukwa.inputtools.mdl

LoaderServer(String) - Constructor for class org.apache.hadoop.chukwa.inputtools.mdl.LoaderServer

Log4jJobHistoryProcessor - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

Log4jJobHistoryProcessor() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Log4jJobHistoryProcessor

Log4JMetricsContext - Class in org.apache.hadoop.chukwa.inputtools.log4j

Log4JMetricsContext() - Constructor for class org.apache.hadoop.chukwa.inputtools.log4j.Log4JMetricsContext

Creates a new instance of FileContext

logApplicationField - Static variable in interface org.apache.hadoop.chukwa.datacollection.connector.Connector

LogEntry - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

LogEntry(String) - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.LogEntry

logEventField - Static variable in interface org.apache.hadoop.chukwa.datacollection.connector.Connector

logLevelField - Static variable in interface org.apache.hadoop.chukwa.extraction.engine.Record

logSourceField - Static variable in interface org.apache.hadoop.chukwa.datacollection.connector.Connector

logTimestampField - Static variable in interface org.apache.hadoop.chukwa.datacollection.connector.Connector

M

Macro - Class in org.apache.hadoop.chukwa.database

Macro(long, String) - Constructor for class org.apache.hadoop.chukwa.database.Macro

Macro(long, long, String) - Constructor for class org.apache.hadoop.chukwa.database.Macro

Macro(long, long, String, HttpServletRequest) - Constructor for class org.apache.hadoop.chukwa.database.Macro

main(String[]) - Static method in class org.apache.hadoop.chukwa.database.Aggregator

main(String[]) - Static method in class org.apache.hadoop.chukwa.database.Consolidator

main(String[]) - Static method in class org.apache.hadoop.chukwa.database.DatabaseConfig

main(String[]) - Static method in class org.apache.hadoop.chukwa.database.DataExpiration

main(String[]) - Static method in class org.apache.hadoop.chukwa.database.MetricsAggregation

main(String[]) - Static method in class org.apache.hadoop.chukwa.database.TableCreator

main(String[]) - Static method in class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

main(String[]) - Static method in class org.apache.hadoop.chukwa.datacollection.collector.CollectorStub

main(String[]) - Static method in class org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController

main(String[]) - Static method in class org.apache.hadoop.chukwa.datacollection.test.FileTailerStressTest

main(String[]) - Static method in class org.apache.hadoop.chukwa.datacollection.test.SinkFileValidator

main(String[]) - Static method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveBuilder

main(String[]) - Static method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveManager

main(String[]) - Static method in class org.apache.hadoop.chukwa.extraction.database.DatabaseLoader

main(String[]) - Static method in class org.apache.hadoop.chukwa.extraction.database.MetricDataLoader

main(String[]) - Static method in class org.apache.hadoop.chukwa.extraction.demux.DailyChukwaRecordRolling

main(String[]) - Static method in class org.apache.hadoop.chukwa.extraction.demux.Demux

main(String[]) - Static method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

main(String[]) - Static method in class org.apache.hadoop.chukwa.extraction.demux.HourlyChukwaRecordRolling

main(String[]) - Static method in class org.apache.hadoop.chukwa.extraction.demux.MoveOrMergeRecordFile

main(String[]) - Static method in class org.apache.hadoop.chukwa.extraction.demux.MoveToRepository

main(String[]) - Static method in class org.apache.hadoop.chukwa.extraction.demux.PostProcessorManager

main(String[]) - Static method in class org.apache.hadoop.chukwa.extraction.engine.datasource.DsDirectory

main(String[]) - Static method in class org.apache.hadoop.chukwa.extraction.engine.datasource.record.ChukwaRecordDataSource

main(String[]) - Static method in class org.apache.hadoop.chukwa.inputtools.jplugin.JPluginAgent

main(String[]) - Static method in class org.apache.hadoop.chukwa.inputtools.log4j.OneLineLogLayout

main(String[]) - Static method in class org.apache.hadoop.chukwa.inputtools.mdl.TorqueDataLoader

main(String[]) - Static method in class org.apache.hadoop.chukwa.inputtools.plugin.metrics.Exec

main(String[]) - Static method in class org.apache.hadoop.chukwa.inputtools.plugin.nodeactivity.NodeActivityPlugin

main(String[]) - Static method in class org.apache.hadoop.chukwa.inputtools.plugin.pbsnode.PbsNodePlugin

main(String[]) - Static method in class org.apache.hadoop.chukwa.util.DumpArchive

main(String[]) - Static method in class org.apache.hadoop.chukwa.util.DumpDataType

main(String[]) - Static method in class org.apache.hadoop.chukwa.util.DumpRecord

main(String[]) - Static method in class org.apache.hadoop.chukwa.util.WatchDog

MalformedFileFormat - Exception in org.apache.hadoop.chukwa.extraction.engine.datasource.record

MalformedFileFormat() - Constructor for exception org.apache.hadoop.chukwa.extraction.engine.datasource.record.MalformedFileFormat

MalformedFileFormat(String, Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.engine.datasource.record.MalformedFileFormat

MalformedFileFormat(String) - Constructor for exception org.apache.hadoop.chukwa.extraction.engine.datasource.record.MalformedFileFormat

MalformedFileFormat(Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.engine.datasource.record.MalformedFileFormat

map(ChukwaArchiveKey, ChunkImpl, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.Demux.MapClass

mapFields - Variable in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT

MapProcessor - Interface in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

MapProcessorFactory - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

MAX_READ_SIZE - Static variable in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

MAX_RETRIES - Static variable in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

MaxRateSender - Class in org.apache.hadoop.chukwa.util

MaxRateSender() - Constructor for class org.apache.hadoop.chukwa.util.MaxRateSender

MDL_XML - Static variable in class org.apache.hadoop.chukwa.database.DatabaseConfig

MemLimitQueue - Class in org.apache.hadoop.chukwa.datacollection.agent

An event queue that blocks once a fixed upper limit of data is enqueued.

MemLimitQueue(int) - Constructor for class org.apache.hadoop.chukwa.datacollection.agent.MemLimitQueue

MetricDataLoader - Class in org.apache.hadoop.chukwa.extraction.database

MetricDataLoader() - Constructor for class org.apache.hadoop.chukwa.extraction.database.MetricDataLoader

Creates a new instance of DBWriter

MetricDataLoader(String) - Constructor for class org.apache.hadoop.chukwa.extraction.database.MetricDataLoader

MetricsAggregation - Class in org.apache.hadoop.chukwa.database

MetricsAggregation() - Constructor for class org.apache.hadoop.chukwa.database.MetricsAggregation

MONTH - Static variable in class org.apache.hadoop.chukwa.database.DatabaseConfig

moveDataSinkFilesToArchiveDirectory(String, String) - Method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

Move sourceFolder inside destFolder

moveDataSinkFilesToArchiveMrInput(FileStatus, String) - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveManager

moveDataSinkFilesToDemuxErrorDirectory(String, String) - Method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

Move sourceFolder inside destFolder

moveDataSinkFilesToDemuxInputDirectory(String, String) - Method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

Move dataSink files to Demux input directory

moveDemuxOutputDirToPostProcessDirectory(String, String) - Method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

Move sourceFolder inside destFolder

moveFolder(String, String, String) - Method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

Move sourceFolder inside destFolder

MoveOrMergeRecordFile - Class in org.apache.hadoop.chukwa.extraction.demux

MoveOrMergeRecordFile() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.MoveOrMergeRecordFile

movetoMainRepository(String, String) - Method in class org.apache.hadoop.chukwa.extraction.demux.PostProcessorManager

MoveToRepository - Class in org.apache.hadoop.chukwa.extraction.demux

MoveToRepository() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.MoveToRepository

MRJobCounters - Class in org.apache.hadoop.chukwa.extraction.database

MRJobCounters() - Constructor for class org.apache.hadoop.chukwa.extraction.database.MRJobCounters

MRJobReduceProcessor - Class in org.apache.hadoop.chukwa.extraction.demux.processor.reducer

MRJobReduceProcessor() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.reducer.MRJobReduceProcessor

N

NAGIOS_CRITICAL - Static variable in class org.apache.hadoop.chukwa.util.NagiosHelper

NAGIOS_OK - Static variable in class org.apache.hadoop.chukwa.util.NagiosHelper

NAGIOS_UNKNOWN - Static variable in class org.apache.hadoop.chukwa.util.NagiosHelper

NAGIOS_WARN - Static variable in class org.apache.hadoop.chukwa.util.NagiosHelper

NagiosHelper - Class in org.apache.hadoop.chukwa.util

NagiosHelper() - Constructor for class org.apache.hadoop.chukwa.util.NagiosHelper

needUUID - Variable in class org.apache.hadoop.chukwa.inputtools.log4j.Log4JMetricsContext

newRecord(String) - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Subclasses should override this if they subclass MetricsRecordImpl.

next() - Method in class org.apache.hadoop.chukwa.datacollection.sender.RetryListOfCollectors

next(LongWritable, Text) - Method in class org.apache.hadoop.chukwa.inputtools.ChukwaInputFormat.ChukwaRecordReader

nextLine() - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.AbstractProcessor

NO_DATASINK_SLEEP_TIME - Variable in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

NodeActivityPlugin - Class in org.apache.hadoop.chukwa.inputtools.plugin.nodeactivity

NodeActivityPlugin() - Constructor for class org.apache.hadoop.chukwa.inputtools.plugin.nodeactivity.NodeActivityPlugin

O

OK - Static variable in class org.apache.hadoop.chukwa.datacollection.writer.ClientAck

OneLineLogLayout - Class in org.apache.hadoop.chukwa.inputtools.log4j

OneLineLogLayout() - Constructor for class org.apache.hadoop.chukwa.inputtools.log4j.OneLineLogLayout

org.apache.hadoop.chukwa - package org.apache.hadoop.chukwa

org.apache.hadoop.chukwa.conf - package org.apache.hadoop.chukwa.conf

org.apache.hadoop.chukwa.database - package org.apache.hadoop.chukwa.database

org.apache.hadoop.chukwa.datacollection - package org.apache.hadoop.chukwa.datacollection

org.apache.hadoop.chukwa.datacollection.adaptor - package org.apache.hadoop.chukwa.datacollection.adaptor

org.apache.hadoop.chukwa.datacollection.adaptor.filetailer - package org.apache.hadoop.chukwa.datacollection.adaptor.filetailer

org.apache.hadoop.chukwa.datacollection.agent - package org.apache.hadoop.chukwa.datacollection.agent

org.apache.hadoop.chukwa.datacollection.agent.metrics - package org.apache.hadoop.chukwa.datacollection.agent.metrics

org.apache.hadoop.chukwa.datacollection.collector - package org.apache.hadoop.chukwa.datacollection.collector

org.apache.hadoop.chukwa.datacollection.collector.servlet - package org.apache.hadoop.chukwa.datacollection.collector.servlet

org.apache.hadoop.chukwa.datacollection.connector - package org.apache.hadoop.chukwa.datacollection.connector

org.apache.hadoop.chukwa.datacollection.connector.http - package org.apache.hadoop.chukwa.datacollection.connector.http

org.apache.hadoop.chukwa.datacollection.controller - package org.apache.hadoop.chukwa.datacollection.controller

org.apache.hadoop.chukwa.datacollection.protocol - package org.apache.hadoop.chukwa.datacollection.protocol

org.apache.hadoop.chukwa.datacollection.sender - package org.apache.hadoop.chukwa.datacollection.sender

org.apache.hadoop.chukwa.datacollection.sender.metrics - package org.apache.hadoop.chukwa.datacollection.sender.metrics

org.apache.hadoop.chukwa.datacollection.test - package org.apache.hadoop.chukwa.datacollection.test

org.apache.hadoop.chukwa.datacollection.writer - package org.apache.hadoop.chukwa.datacollection.writer

org.apache.hadoop.chukwa.extraction - package org.apache.hadoop.chukwa.extraction

org.apache.hadoop.chukwa.extraction.archive - package org.apache.hadoop.chukwa.extraction.archive

org.apache.hadoop.chukwa.extraction.database - package org.apache.hadoop.chukwa.extraction.database

org.apache.hadoop.chukwa.extraction.demux - package org.apache.hadoop.chukwa.extraction.demux

org.apache.hadoop.chukwa.extraction.demux.processor - package org.apache.hadoop.chukwa.extraction.demux.processor

org.apache.hadoop.chukwa.extraction.demux.processor.mapper - package org.apache.hadoop.chukwa.extraction.demux.processor.mapper

org.apache.hadoop.chukwa.extraction.demux.processor.reducer - package org.apache.hadoop.chukwa.extraction.demux.processor.reducer

org.apache.hadoop.chukwa.extraction.engine - package org.apache.hadoop.chukwa.extraction.engine

org.apache.hadoop.chukwa.extraction.engine.datasource - package org.apache.hadoop.chukwa.extraction.engine.datasource

org.apache.hadoop.chukwa.extraction.engine.datasource.database - package org.apache.hadoop.chukwa.extraction.engine.datasource.database

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

org.apache.hadoop.chukwa.hicc - package org.apache.hadoop.chukwa.hicc

org.apache.hadoop.chukwa.inputtools - package org.apache.hadoop.chukwa.inputtools

org.apache.hadoop.chukwa.inputtools.hdfsusage - package org.apache.hadoop.chukwa.inputtools.hdfsusage

org.apache.hadoop.chukwa.inputtools.jplugin - package org.apache.hadoop.chukwa.inputtools.jplugin

org.apache.hadoop.chukwa.inputtools.log4j - package org.apache.hadoop.chukwa.inputtools.log4j

org.apache.hadoop.chukwa.inputtools.mdl - package org.apache.hadoop.chukwa.inputtools.mdl

org.apache.hadoop.chukwa.inputtools.plugin - package org.apache.hadoop.chukwa.inputtools.plugin

org.apache.hadoop.chukwa.inputtools.plugin.metrics - package org.apache.hadoop.chukwa.inputtools.plugin.metrics

org.apache.hadoop.chukwa.inputtools.plugin.nodeactivity - package org.apache.hadoop.chukwa.inputtools.plugin.nodeactivity

org.apache.hadoop.chukwa.inputtools.plugin.pbsnode - package org.apache.hadoop.chukwa.inputtools.plugin.pbsnode

org.apache.hadoop.chukwa.util - package org.apache.hadoop.chukwa.util

org.apache.hadoop.metrics.spi - package org.apache.hadoop.metrics.spi

OrgChart - Interface in org.apache.hadoop.chukwa.inputtools.hdfsusage

OUTPUT_DIR_PROPERTY - Static variable in class org.apache.hadoop.chukwa.inputtools.log4j.Log4JMetricsContext

outputDir - Variable in class org.apache.hadoop.chukwa.inputtools.log4j.Log4JMetricsContext

P

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.AbstractProcessor

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.ClientTraceProcessor

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.DebugOutputProcessor

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.DefaultProcessor

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Df

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.HadoopLogProcessor

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.HadoopMetricsProcessor

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Iostat

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobConfProcessor

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLog

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLogHistoryProcessor

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JPluginMapper

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Log4jJobHistoryProcessor

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.PbsNodes

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Ps

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Sar

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.SysLog

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Top

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Torque

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.TsProcessor

parse(String, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.YWatch

parseData(String) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Iostat

parseData(String) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Sar

parseFrom(byte[]) - Method in interface org.apache.hadoop.chukwa.datacollection.protocol.Protocol

parseFrom(InputStream) - Method in interface org.apache.hadoop.chukwa.datacollection.protocol.Protocol

parseHeader(String) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Iostat

parseHeader(String) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Sar

parsePbsRecord(String, ChukwaRecord) - Static method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.PbsNodes

parseStatusField(String, ChukwaRecord) - Static method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.PbsNodes

parseSummary(ChukwaRecord, String) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Top

pauseFile(String, String) - Method in class org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController

Pause all active adaptors of the default file tailing type who are tailing this file This means we actually stop the adaptor and it goes away forever, but we store it state so that we can re-launch a new adaptor with the same state later.

PbsInvalidEntry - Exception in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

PbsInvalidEntry() - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.PbsInvalidEntry

PbsInvalidEntry(String) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.PbsInvalidEntry

PbsInvalidEntry(Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.PbsInvalidEntry

PbsInvalidEntry(String, Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.PbsInvalidEntry

PbsNodePlugin - Class in org.apache.hadoop.chukwa.inputtools.plugin.pbsnode

PbsNodePlugin() - Constructor for class org.apache.hadoop.chukwa.inputtools.plugin.pbsnode.PbsNodePlugin

PbsNodes - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

PbsNodes() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.PbsNodes

period - Variable in class org.apache.hadoop.chukwa.inputtools.log4j.Log4JMetricsContext

PERIOD_PROPERTY - Static variable in class org.apache.hadoop.chukwa.inputtools.log4j.Log4JMetricsContext

PidFile - Class in org.apache.hadoop.chukwa.util

PidFile(String) - Constructor for class org.apache.hadoop.chukwa.util.PidFile

PipelineableWriter - Interface in org.apache.hadoop.chukwa.datacollection.writer

PipelineStageWriter - Class in org.apache.hadoop.chukwa.datacollection.writer

PipelineStageWriter() - Constructor for class org.apache.hadoop.chukwa.datacollection.writer.PipelineStageWriter

plot() - Method in class org.apache.hadoop.chukwa.hicc.Chart

portno - Variable in class org.apache.hadoop.chukwa.datacollection.agent.AgentControlSocketListener

postProcess(JSONObject) - Method in class org.apache.hadoop.chukwa.inputtools.plugin.ExecPlugin

postProcess(JSONObject) - Method in class org.apache.hadoop.chukwa.inputtools.plugin.nodeactivity.NodeActivityPlugin

PostProcessorManager - Class in org.apache.hadoop.chukwa.extraction.demux

PostProcessorManager() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.PostProcessorManager

PostProcessorManager(ChukwaConfiguration) - Constructor for class org.apache.hadoop.chukwa.extraction.demux.PostProcessorManager

printPage(PrintStream) - Static method in class org.apache.hadoop.chukwa.datacollection.collector.servlet.ServletDiagnostics

process(long, long, String) - Method in class org.apache.hadoop.chukwa.database.Aggregator

process(String) - Method in class org.apache.hadoop.chukwa.database.Aggregator

process(SequenceFile.Reader) - Method in interface org.apache.hadoop.chukwa.extraction.database.DBPlugin

process(Path) - Method in class org.apache.hadoop.chukwa.extraction.database.MetricDataLoader

process(SequenceFile.Reader) - Method in class org.apache.hadoop.chukwa.extraction.database.MRJobCounters

process(ChukwaArchiveKey, Chunk, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.AbstractProcessor

process(Chunk, OutputCollector<Text, ChukwaRecord>, Reporter) - Method in interface org.apache.hadoop.chukwa.extraction.demux.processor.mapper.ChunkProcessor

process(ChukwaArchiveKey, Chunk, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in interface org.apache.hadoop.chukwa.extraction.demux.processor.mapper.MapProcessor

process(ChukwaRecordKey, Iterator<ChukwaRecord>, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.reducer.ClientTrace

process(ChukwaRecordKey, Iterator<ChukwaRecord>, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.reducer.IdentityReducer

process(ChukwaRecordKey, Iterator<ChukwaRecord>, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.reducer.JobLogHistoryReduceProcessor

process(ChukwaRecordKey, Iterator<ChukwaRecord>, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.reducer.MRJobReduceProcessor

process(ChukwaRecordKey, Iterator<ChukwaRecord>, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in interface org.apache.hadoop.chukwa.extraction.demux.processor.reducer.ReduceProcessor

process(ChukwaRecordKey, Iterator<ChukwaRecord>, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.reducer.SystemMetrics

processCommand(String) - Method in class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

processData(String, String, String, String, String) - Method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

Process Data, i.e.

processDay(FileStatus, String, String, String) - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveManager

processDemuxOutput(String) - Method in class org.apache.hadoop.chukwa.extraction.demux.PostProcessorManager

ProcessorFactory - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

Protocol - Interface in org.apache.hadoop.chukwa.datacollection.protocol

PROTOCOL_VERSION - Static variable in class org.apache.hadoop.chukwa.ChunkImpl

proxyRetryField - Static variable in interface org.apache.hadoop.chukwa.datacollection.connector.Connector

proxyTimestampField - Static variable in interface org.apache.hadoop.chukwa.datacollection.connector.Connector

proxyURIField - Static variable in interface org.apache.hadoop.chukwa.datacollection.connector.Connector

Ps - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

Ps() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Ps

Ps.InvalidPsRecord - Exception in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

Ps.InvalidPsRecord() - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Ps.InvalidPsRecord

Ps.InvalidPsRecord(String) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Ps.InvalidPsRecord

Ps.InvalidPsRecord(Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Ps.InvalidPsRecord

Ps.InvalidPsRecord(String, Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Ps.InvalidPsRecord

Ps.PsOutput - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

Ps.PsOutput(String) - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Ps.PsOutput

put(String, String) - Method in class org.apache.hadoop.chukwa.database.DatabaseConfig

put(String, String) - Method in class org.apache.hadoop.chukwa.inputtools.mdl.DataConfig

Q

QUARTER - Static variable in class org.apache.hadoop.chukwa.database.DatabaseConfig

query(String) - Method in class org.apache.hadoop.chukwa.util.DatabaseWriter

queueSize - Variable in class org.apache.hadoop.chukwa.datacollection.agent.metrics.ChunkQueueMetrics

R

read(DataInput) - Static method in class org.apache.hadoop.chukwa.ChunkImpl

readConfig() - Static method in class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

readData(String, String, int, long, long, long, String, String, FileSystem) - Static method in class org.apache.hadoop.chukwa.extraction.engine.datasource.record.ChukwaFileParser

readData(ChukwaDSInternalResult, Token, String, int, long, long, String) - Method in class org.apache.hadoop.chukwa.extraction.engine.datasource.record.ChukwaRecordDataSource

readData(String, String, int, long, long, long, String, String, FileSystem, Configuration) - Static method in class org.apache.hadoop.chukwa.extraction.engine.datasource.record.ChukwaSequenceFileParser

reader - Variable in class org.apache.hadoop.chukwa.datacollection.adaptor.FileAdaptor

reader - Variable in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

readFields(DataInput) - Method in class org.apache.hadoop.chukwa.ChunkImpl

readOutChunk(int, int) - Method in class org.apache.hadoop.chukwa.datacollection.writer.InMemoryWriter

Try to read bytes, waiting up to ms

Record - Interface in org.apache.hadoop.chukwa.extraction.engine

RECORD_SEPARATOR_ESCAPE_SEQ - Static variable in class org.apache.hadoop.chukwa.util.RecordConstants

RecordConstants - Class in org.apache.hadoop.chukwa.util

RecordConstants() - Constructor for class org.apache.hadoop.chukwa.util.RecordConstants

RecordDS - Class in org.apache.hadoop.chukwa.extraction.engine.datasource.record

RecordDS() - Constructor for class org.apache.hadoop.chukwa.extraction.engine.datasource.record.RecordDS

RecordMerger - Class in org.apache.hadoop.chukwa.extraction.demux

RecordMerger(ChukwaConfiguration, FileSystem, Tool, String[], boolean) - Constructor for class org.apache.hadoop.chukwa.extraction.demux.RecordMerger

recordType - Static variable in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.DebugOutputProcessor

recordType - Variable in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Iostat

recordType - Variable in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Sar

recordType - Variable in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Top

RecordUtil - Class in org.apache.hadoop.chukwa.extraction.engine

RecordUtil() - Constructor for class org.apache.hadoop.chukwa.extraction.engine.RecordUtil

recoverRecordSeparators(String, String) - Static method in class org.apache.hadoop.chukwa.util.RecordConstants

reduce(ChukwaRecordKey, Iterator<ChukwaRecord>, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Method in class org.apache.hadoop.chukwa.extraction.demux.Demux.ReduceClass

ReduceProcessor - Interface in org.apache.hadoop.chukwa.extraction.demux.processor.reducer

ReduceProcessorFactory - Class in org.apache.hadoop.chukwa.extraction.demux.processor.reducer

register(String, ChunkProcessor) - Static method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.ProcessorFactory

Register a specific parser for a ChunkProcessor implementation.

register(String, ReduceProcessor) - Static method in class org.apache.hadoop.chukwa.extraction.demux.processor.reducer.ReduceProcessorFactory

Register a specific parser for a ReduceProcessor implementation.

registerUpdater(Updater) - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Registers a callback to be called at time intervals determined by the configuration.

registry - Variable in class org.apache.hadoop.chukwa.datacollection.agent.metrics.AgentMetrics

registry - Variable in class org.apache.hadoop.chukwa.datacollection.agent.metrics.ChunkQueueMetrics

registry - Variable in class org.apache.hadoop.chukwa.datacollection.sender.metrics.HttpSenderMetrics

releaseLock(int, Throwable) - Method in class org.apache.hadoop.chukwa.datacollection.writer.ClientAck

reloadConfiguration() - Method in interface org.apache.hadoop.chukwa.datacollection.connector.Connector

reloadConfiguration() - Method in class org.apache.hadoop.chukwa.datacollection.connector.http.HttpConnector

reloadConfiguration() - Method in class org.apache.hadoop.chukwa.datacollection.test.ConsoleOutConnector

remove(long) - Method in class org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController

remove(String, String, String) - Method in class org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController

remove() - Method in class org.apache.hadoop.chukwa.datacollection.sender.RetryListOfCollectors

remove(MetricsRecordImpl) - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Called by MetricsRecordImpl.remove().

removeAll() - Method in class org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController

removedAdaptor - Variable in class org.apache.hadoop.chukwa.datacollection.agent.metrics.AgentMetrics

removedChunk - Variable in class org.apache.hadoop.chukwa.datacollection.agent.metrics.ChunkQueueMetrics

removeFile(String, String) - Method in class org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController

removeValue(String) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecord

reportCommit(Adaptor, long) - Method in class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

reportTaskEnd(TaskAttemptID) - Method in class org.apache.hadoop.chukwa.inputtools.ChukwaTTInstru

reportTaskLaunch(TaskAttemptID, File, File) - Method in class org.apache.hadoop.chukwa.inputtools.ChukwaTTInstru

reprocess - Variable in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

reset(Chunk) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.AbstractProcessor

restoreFromCheckpoint() - Method in class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

Tries to restore from a checkpoint file in checkpointDir.

resumeFile(String, String) - Method in class org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController

Resume all adaptors for this filename that have been paused

RetryListOfCollectors - Class in org.apache.hadoop.chukwa.datacollection.sender

An iterator returning a list of Collectors to try.

RetryListOfCollectors(File, int) - Constructor for class org.apache.hadoop.chukwa.datacollection.sender.RetryListOfCollectors

RetryListOfCollectors(List<String>, int) - Constructor for class org.apache.hadoop.chukwa.datacollection.sender.RetryListOfCollectors

run() - Method in class org.apache.hadoop.chukwa.database.Consolidator

run() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.TerminatorThread

run() - Method in class org.apache.hadoop.chukwa.datacollection.agent.AgentControlSocketListener

Binds to socket, starts looping listening for commands

run() - Method in class org.apache.hadoop.chukwa.datacollection.connector.http.HttpConnector

run() - Method in class org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController.AddAdaptorTask

run() - Method in class org.apache.hadoop.chukwa.datacollection.test.ConsoleOutConnector

run(String[]) - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveBuilder

run(String[]) - Method in class org.apache.hadoop.chukwa.extraction.demux.DailyChukwaRecordRolling

run(String[]) - Method in class org.apache.hadoop.chukwa.extraction.demux.Demux

run(String[]) - Method in class org.apache.hadoop.chukwa.extraction.demux.HourlyChukwaRecordRolling

run(String[]) - Method in class org.apache.hadoop.chukwa.extraction.demux.MoveOrMergeRecordFile

run() - Method in class org.apache.hadoop.chukwa.extraction.demux.RecordMerger

run() - Method in class org.apache.hadoop.chukwa.inputtools.mdl.ErStreamHandler

run() - Method in class org.apache.hadoop.chukwa.inputtools.mdl.TorqueDataLoader

run() - Method in class org.apache.hadoop.chukwa.inputtools.mdl.TorqueTimerTask

run() - Method in class org.apache.hadoop.chukwa.inputtools.plugin.metrics.Exec

run() - Method in class org.apache.hadoop.chukwa.util.ConstRateAdaptor

run() - Method in class org.apache.hadoop.chukwa.util.MaxRateSender

run() - Method in class org.apache.hadoop.chukwa.util.PidFile

run() - Method in class org.apache.hadoop.chukwa.util.WatchDog

run_forever() - Method in class org.apache.hadoop.chukwa.inputtools.mdl.TorqueInfoProcessor

runArchive(String, String, String) - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveManager

runDemux(String, String) - Method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

Submit and Run demux Job

S

s - Variable in class org.apache.hadoop.chukwa.datacollection.agent.AgentControlSocketListener

Sar - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

Sar() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Sar

saveChunk(Chunk, Throwable, OutputCollector<ChukwaRecordKey, ChukwaRecord>, Reporter) - Static method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.ChunkSaver

saveChunkInError(Throwable) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.AbstractProcessor

saveView(HttpServletRequest, HttpServletResponse) - Method in class org.apache.hadoop.chukwa.hicc.Workspace

sawChunk(ChunkImpl, int) - Method in class org.apache.hadoop.chukwa.datacollection.collector.servlet.ServletDiagnostics

sawPost(String, int, long) - Method in class org.apache.hadoop.chukwa.datacollection.collector.servlet.ServletDiagnostics

search(String, String[], long, long, String, Token) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaSearchService

search(SearchResult, String, String, long, long, String, Token) - Method in class org.apache.hadoop.chukwa.extraction.engine.datasource.database.DatabaseDS

search(SearchResult, String, String, long, long, String, Token) - Method in interface org.apache.hadoop.chukwa.extraction.engine.datasource.DataSource

search(SearchResult, String, String, long, long, String, Token) - Method in class org.apache.hadoop.chukwa.extraction.engine.datasource.record.ChukwaRecordDataSource

search(SearchResult, String, String, long, long, String, Token) - Method in class org.apache.hadoop.chukwa.extraction.engine.datasource.record.RecordDS

search(String, String[], long, long, String, Token) - Method in interface org.apache.hadoop.chukwa.extraction.engine.SearchService

SearchResult - Interface in org.apache.hadoop.chukwa.extraction.engine

SearchService - Interface in org.apache.hadoop.chukwa.extraction.engine

send(List<Chunk>) - Method in class org.apache.hadoop.chukwa.datacollection.sender.ChukwaHttpSender

grab all of the chunks currently in the chunkQueue, stores a copy of them locally, calculates their size, sets them up

send(List<Chunk>) - Method in interface org.apache.hadoop.chukwa.datacollection.sender.ChukwaSender

sendAlert - Variable in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

sendDemuxStatusToNagios(String, int, String, String, boolean, String) - Method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

Send NSCA status to Nagios

sendNsca(String, int, String, String, String, int) - Static method in class org.apache.hadoop.chukwa.util.NagiosHelper

SeqFileWriter - Class in org.apache.hadoop.chukwa.datacollection.writer

This class is thread-safe -- rotate() and save() both synchronize on this object.

SeqFileWriter() - Constructor for class org.apache.hadoop.chukwa.datacollection.writer.SeqFileWriter

serialize(RecordOutput, String) - Method in class org.apache.hadoop.chukwa.ChukwaArchiveKey

serialize(RecordOutput, String) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT

serialize(RecordOutput, String) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey

serialVersionUID - Static variable in class org.apache.hadoop.chukwa.hicc.Iframe

serialVersionUID - Static variable in class org.apache.hadoop.chukwa.hicc.Workspace

ServletCollector - Class in org.apache.hadoop.chukwa.datacollection.collector.servlet

ServletCollector(Configuration) - Constructor for class org.apache.hadoop.chukwa.datacollection.collector.servlet.ServletCollector

ServletDiagnostics - Class in org.apache.hadoop.chukwa.datacollection.collector.servlet

One per post

ServletDiagnostics() - Constructor for class org.apache.hadoop.chukwa.datacollection.collector.servlet.ServletDiagnostics

setApplication(String) - Method in interface org.apache.hadoop.chukwa.Chunk

setApplication(String) - Method in class org.apache.hadoop.chukwa.ChunkImpl

setChukwaClientConnectNumRetry(int) - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

setChukwaClientConnectRetryInterval(long) - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

setChukwaClientHostname(String) - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

setChukwaClientPortNum(int) - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

setCleanUpRegex(String) - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

setCollectors(String) - Method in class org.apache.hadoop.chukwa.datacollection.sender.ChukwaHttpSender

Set up a single connector for this client to send Chunks to

setCollectors(Iterator<String>) - Method in class org.apache.hadoop.chukwa.datacollection.sender.ChukwaHttpSender

Set up a list of connectors for this client to send Chunks to

setCollectors(Iterator<String>) - Method in interface org.apache.hadoop.chukwa.datacollection.sender.ChukwaSender

setContents(String, String) - Method in class org.apache.hadoop.chukwa.hicc.Workspace

setData(byte[]) - Method in interface org.apache.hadoop.chukwa.Chunk

setData(byte[]) - Method in class org.apache.hadoop.chukwa.ChunkImpl

setDataSet(String, TreeMap<String, TreeMap<String, Double>>) - Method in class org.apache.hadoop.chukwa.hicc.Chart

setDataType(String) - Method in class org.apache.hadoop.chukwa.ChukwaArchiveKey

setDataType(String) - Method in interface org.apache.hadoop.chukwa.Chunk

setDataType(String) - Method in class org.apache.hadoop.chukwa.ChunkImpl

setDate(Date) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.LogEntry

setDatePattern(String) - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

The DatePattern takes a string in the same format as expected by SimpleDateFormat.

setDebugInfo(String) - Method in class org.apache.hadoop.chukwa.ChunkImpl

setDisplayPercentage(boolean) - Method in class org.apache.hadoop.chukwa.hicc.Chart

setException(Throwable) - Method in class org.apache.hadoop.chukwa.datacollection.writer.ClientAck

setGraphType(String) - Method in class org.apache.hadoop.chukwa.hicc.Chart

setId(String) - Method in class org.apache.hadoop.chukwa.hicc.Chart

setId(String) - Method in class org.apache.hadoop.chukwa.inputtools.hdfsusage.Employee

setInitiator(Adaptor) - Method in class org.apache.hadoop.chukwa.ChunkImpl

setKey(String) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey

setKey(String) - Method in class org.apache.hadoop.chukwa.inputtools.jplugin.GenericChukwaMetricsList.GenericChukwaMetrics

setLastModified(long) - Method in class org.apache.hadoop.chukwa.inputtools.hdfsusage.HDFSUsageMetrics

setLegend(boolean) - Method in class org.apache.hadoop.chukwa.hicc.Chart

setLogSource() - Method in class org.apache.hadoop.chukwa.ChunkImpl

setLogType(String) - Method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLog.JobLogLine

setManager(Employee) - Method in class org.apache.hadoop.chukwa.inputtools.hdfsusage.Employee

setMapFields(TreeMap<String, Buffer>) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT

setMaxBackupIndex(int) - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

setMetricsList(ArrayList<T>) - Method in class org.apache.hadoop.chukwa.inputtools.jplugin.ChukwaMetricsList

setName(String) - Method in class org.apache.hadoop.chukwa.inputtools.hdfsusage.HDFSUsageMetrics

setNextStage(ChukwaWriter) - Method in class org.apache.hadoop.chukwa.datacollection.writer.Dedup

setNextStage(ChukwaWriter) - Method in interface org.apache.hadoop.chukwa.datacollection.writer.PipelineableWriter

setPeriod(int) - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Sets the timer period

setProtocolVersion(int) - Method in class org.apache.hadoop.chukwa.ChunkImpl

setRecordOffsets(int[]) - Method in interface org.apache.hadoop.chukwa.Chunk

setRecordOffsets(int[]) - Method in class org.apache.hadoop.chukwa.ChunkImpl

setRecordOffsets(Collection<Integer>) - Method in class org.apache.hadoop.chukwa.ChunkImpl

setRecords(TreeMap<Long, List<Record>>) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaSearchResult

setRecords(TreeMap<Long, List<Record>>) - Method in interface org.apache.hadoop.chukwa.extraction.engine.SearchResult

setRecordType(String) - Method in class org.apache.hadoop.chukwa.inputtools.jplugin.ChukwaMetricsList

setRecordType(String) - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

setReduceType(String) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey

setSeqId(long) - Method in class org.apache.hadoop.chukwa.ChukwaArchiveKey

setSeqID(long) - Method in interface org.apache.hadoop.chukwa.Chunk

setSeqID(long) - Method in class org.apache.hadoop.chukwa.ChunkImpl

setSeriesOrder(String[]) - Method in class org.apache.hadoop.chukwa.hicc.Chart

setSize(int, int) - Method in class org.apache.hadoop.chukwa.hicc.Chart

setSize(Long) - Method in class org.apache.hadoop.chukwa.inputtools.hdfsusage.HDFSUsageMetrics

setSource(String) - Method in interface org.apache.hadoop.chukwa.Chunk

setSource(String) - Method in class org.apache.hadoop.chukwa.ChunkImpl

setStatus(int) - Method in class org.apache.hadoop.chukwa.datacollection.writer.ClientAck

setStreamName(String) - Method in class org.apache.hadoop.chukwa.ChukwaArchiveKey

setStreamName(String) - Method in interface org.apache.hadoop.chukwa.Chunk

setStreamName(String) - Method in class org.apache.hadoop.chukwa.ChunkImpl

setTime(long) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT

setTimePartition(long) - Method in class org.apache.hadoop.chukwa.ChukwaArchiveKey

setTimestamp(long) - Method in class org.apache.hadoop.chukwa.inputtools.jplugin.ChukwaMetricsList

setTitle(String) - Method in class org.apache.hadoop.chukwa.hicc.Chart

setToken(Token) - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaSearchResult

setToken(Token) - Method in interface org.apache.hadoop.chukwa.extraction.engine.SearchResult

setTypeFilter(RecordTypeInfo) - Static method in class org.apache.hadoop.chukwa.ChukwaArchiveKey

setTypeFilter(RecordTypeInfo) - Static method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT

setTypeFilter(RecordTypeInfo) - Static method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey

setup(Path) - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveManager

Create directory if !exists

setup(Path) - Method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

Create directory if !exists

setup(boolean) - Method in class org.apache.hadoop.chukwa.inputtools.mdl.TorqueInfoProcessor

setWriter(DatabaseWriter) - Method in class org.apache.hadoop.chukwa.database.Aggregator

setWriter(ChukwaWriter) - Static method in class org.apache.hadoop.chukwa.datacollection.collector.servlet.ServletCollector

setXAxisLabel(String) - Method in class org.apache.hadoop.chukwa.hicc.Chart

setXAxisLabels(boolean) - Method in class org.apache.hadoop.chukwa.hicc.Chart

setXLabelsRange(List<String>) - Method in class org.apache.hadoop.chukwa.hicc.Chart

setYAxisLabel(String) - Method in class org.apache.hadoop.chukwa.hicc.Chart

setYAxisLabels(boolean) - Method in class org.apache.hadoop.chukwa.hicc.Chart

setYAxisRightLabel(String) - Method in class org.apache.hadoop.chukwa.hicc.Chart

setYAxisRightLabels(boolean) - Method in class org.apache.hadoop.chukwa.hicc.Chart

setYMax(double) - Method in class org.apache.hadoop.chukwa.hicc.Chart

setYMin(double) - Method in class org.apache.hadoop.chukwa.hicc.Chart

shutdown() - Method in interface org.apache.hadoop.chukwa.datacollection.adaptor.Adaptor

Signals this adaptor to come to an orderly stop.

shutdown() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.ExecAdaptor

shutdown() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.FileAdaptor

We want to keep trying

shutdown() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

Do one last tail, and then stop

shutdown() - Method in class org.apache.hadoop.chukwa.datacollection.agent.AgentControlSocketListener

Close the control socket, and exit.

shutdown() - Method in class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

shutdown(boolean) - Method in class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

Triggers agent shutdown.

shutdown() - Method in class org.apache.hadoop.chukwa.datacollection.agent.metrics.AgentActivityMBean

shutdown() - Method in class org.apache.hadoop.chukwa.datacollection.agent.metrics.AgentMetrics

shutdown() - Method in class org.apache.hadoop.chukwa.datacollection.agent.metrics.ChunkQueueActivityMBean

shutdown() - Method in class org.apache.hadoop.chukwa.datacollection.agent.metrics.ChunkQueueMetrics

shutdown() - Method in interface org.apache.hadoop.chukwa.datacollection.connector.Connector

shutdown() - Method in class org.apache.hadoop.chukwa.datacollection.connector.http.HttpConnector

shutdown() - Method in class org.apache.hadoop.chukwa.datacollection.sender.metrics.HttpSenderActivityMBean

shutdown() - Method in class org.apache.hadoop.chukwa.datacollection.sender.metrics.HttpSenderMetrics

shutdown() - Method in class org.apache.hadoop.chukwa.datacollection.test.ConsoleOutConnector

shutdown() - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveManager

shutdown() - Method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

shutdown() - Method in class org.apache.hadoop.chukwa.extraction.demux.PostProcessorManager

shutdown() - Method in class org.apache.hadoop.chukwa.inputtools.mdl.TorqueInfoProcessor

shutdown() - Method in class org.apache.hadoop.chukwa.util.ConstRateAdaptor

shutdown() - Method in class org.apache.hadoop.chukwa.util.MaxRateSender

shutdownCalled - Variable in class org.apache.hadoop.chukwa.datacollection.adaptor.FileAdaptor

signature() - Static method in class org.apache.hadoop.chukwa.ChukwaArchiveKey

signature() - Static method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT

signature() - Static method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey

SinkFileValidator - Class in org.apache.hadoop.chukwa.datacollection.test

SinkFileValidator() - Constructor for class org.apache.hadoop.chukwa.datacollection.test.SinkFileValidator

size() - Method in class org.apache.hadoop.chukwa.datacollection.agent.MemLimitQueue

size() - Method in class org.apache.hadoop.chukwa.datacollection.agent.WaitingQueue

size() - Method in interface org.apache.hadoop.chukwa.datacollection.ChunkQueue

Return an approximation of the number of chunks in the queue currently.

slurpRaw(byte[], int, int) - Static method in class org.apache.hadoop.chukwa.ChukwaArchiveKey.Comparator

slurpRaw(byte[], int, int) - Static method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT.Comparator

slurpRaw(byte[], int, int) - Static method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey.Comparator

sourceField - Static variable in interface org.apache.hadoop.chukwa.extraction.engine.Record

split(String, String) - Static method in class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.JobLog

start(long, String, String, long, ChunkReceiver) - Method in interface org.apache.hadoop.chukwa.datacollection.adaptor.Adaptor

Start this adaptor

start(long, String, String, long, ChunkReceiver) - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.ExecAdaptor

start(long, String, String, long, ChunkReceiver) - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.FileAdaptor

start(long, String, String, long, ChunkReceiver) - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

start() - Method in interface org.apache.hadoop.chukwa.datacollection.connector.Connector

start() - Method in class org.apache.hadoop.chukwa.datacollection.connector.http.HttpConnector

start() - Method in class org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveManager

start() - Method in class org.apache.hadoop.chukwa.extraction.demux.DemuxManager

Start the Demux Manager daemon

start() - Method in class org.apache.hadoop.chukwa.extraction.demux.PostProcessorManager

start(long, String, String, long, ChunkReceiver) - Method in class org.apache.hadoop.chukwa.util.ConstRateAdaptor

start(long, String, String, long, ChunkReceiver) - Method in class org.apache.hadoop.chukwa.util.MaxRateSender

startMonitoring() - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Starts or restarts monitoring, the emitting of metrics records.

startWith(String) - Method in class org.apache.hadoop.chukwa.database.DatabaseConfig

startWith(String) - Method in class org.apache.hadoop.chukwa.inputtools.mdl.DataConfig

statusKO - Variable in class org.apache.hadoop.chukwa.inputtools.plugin.ExecPlugin

statusOK - Variable in class org.apache.hadoop.chukwa.inputtools.plugin.ExecPlugin

stop() - Method in class org.apache.hadoop.chukwa.inputtools.plugin.ExecPlugin

stopAdaptor(long, boolean) - Method in class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

Stop the adaptor with given ID number.

stopMonitoring() - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Stops monitoring.

subAppend(LoggingEvent) - Method in class org.apache.hadoop.chukwa.inputtools.log4j.ChukwaDailyRollingFileAppender

This method differentiates DailyRollingFileAppender from its super class.

SysLog - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

SysLog() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.SysLog

SystemMetrics - Class in org.apache.hadoop.chukwa.extraction.demux.processor.reducer

SystemMetrics() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.reducer.SystemMetrics

T

TableCreator - Class in org.apache.hadoop.chukwa.database

TableCreator() - Constructor for class org.apache.hadoop.chukwa.database.TableCreator

tag(String, Record) - Method in interface org.apache.hadoop.chukwa.extraction.demux.TaggerPlugin

TaggerPlugin - Interface in org.apache.hadoop.chukwa.extraction.demux

tagsField - Static variable in interface org.apache.hadoop.chukwa.extraction.engine.Record

tailFile(ChunkReceiver) - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

Looks at the tail of the associated file, adds some of it to event queue This method is not thread safe.

TerminatorThread - Class in org.apache.hadoop.chukwa.datacollection.adaptor.filetailer

TerminatorThread(FileTailingAdaptor, ChunkReceiver) - Constructor for class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.TerminatorThread

time - Variable in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordJT

TimeHandler - Class in org.apache.hadoop.chukwa.hicc

TimeHandler(HttpServletRequest) - Constructor for class org.apache.hadoop.chukwa.hicc.TimeHandler

TimeHandler(HttpServletRequest, String) - Constructor for class org.apache.hadoop.chukwa.hicc.TimeHandler

timeoutInterval - Static variable in class org.apache.hadoop.chukwa.inputtools.mdl.TorqueTimerTask

toByteArray(List<Chunk>) - Method in interface org.apache.hadoop.chukwa.datacollection.protocol.Protocol

Token - Class in org.apache.hadoop.chukwa.extraction.engine

Token() - Constructor for class org.apache.hadoop.chukwa.extraction.engine.Token

Top - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

Top() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Top

Torque - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

Torque() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.Torque

TorqueDataLoader - Class in org.apache.hadoop.chukwa.inputtools.mdl

TorqueDataLoader(DataConfig, int) - Constructor for class org.apache.hadoop.chukwa.inputtools.mdl.TorqueDataLoader

TorqueInfoProcessor - Class in org.apache.hadoop.chukwa.inputtools.mdl

TorqueInfoProcessor(DataConfig, int) - Constructor for class org.apache.hadoop.chukwa.inputtools.mdl.TorqueInfoProcessor

TorqueTimerTask - Class in org.apache.hadoop.chukwa.inputtools.mdl

TorqueTimerTask() - Constructor for class org.apache.hadoop.chukwa.inputtools.mdl.TorqueTimerTask

TorqueTimerTask(Process, String) - Constructor for class org.apache.hadoop.chukwa.inputtools.mdl.TorqueTimerTask

toString() - Method in class org.apache.hadoop.chukwa.ChunkImpl

toString() - Method in class org.apache.hadoop.chukwa.database.Macro

toString() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.CharFileTailingAdaptorUTF8NewLineEscaped

toString() - Method in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

toString() - Method in class org.apache.hadoop.chukwa.extraction.engine.ChukwaRecord

toString() - Method in interface org.apache.hadoop.chukwa.extraction.engine.Record

toString() - Method in class org.apache.hadoop.chukwa.util.ConstRateAdaptor

toString() - Method in class org.apache.hadoop.chukwa.util.MaxRateSender

toWatch - Variable in class org.apache.hadoop.chukwa.datacollection.adaptor.FileAdaptor

toXml() - Method in class org.apache.hadoop.chukwa.inputtools.jplugin.ChukwaMetricsList

tryToBind() - Method in class org.apache.hadoop.chukwa.datacollection.agent.AgentControlSocketListener

TsProcessor - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

TsProcessor() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.TsProcessor

type - Variable in class org.apache.hadoop.chukwa.datacollection.adaptor.FileAdaptor

type - Variable in class org.apache.hadoop.chukwa.datacollection.adaptor.filetailer.FileTailingAdaptor

U

UnknownRecordTypeException - Exception in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

UnknownRecordTypeException() - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.UnknownRecordTypeException

UnknownRecordTypeException(String) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.UnknownRecordTypeException

UnknownRecordTypeException(Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.UnknownRecordTypeException

UnknownRecordTypeException(String, Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.UnknownRecordTypeException

UnknownReduceTypeException - Exception in org.apache.hadoop.chukwa.extraction.demux.processor.reducer

UnknownReduceTypeException() - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.reducer.UnknownReduceTypeException

UnknownReduceTypeException(String) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.reducer.UnknownReduceTypeException

UnknownReduceTypeException(Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.reducer.UnknownReduceTypeException

UnknownReduceTypeException(String, Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.reducer.UnknownReduceTypeException

unregisterUpdater(Updater) - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Removes a callback, if it exists.

update(MetricsRecordImpl) - Method in class org.apache.hadoop.metrics.spi.AbstractMetricsContext

Called by MetricsRecordImpl.update().

usage() - Static method in class org.apache.hadoop.chukwa.database.DataExpiration

usage() - Static method in class org.apache.hadoop.chukwa.database.TableCreator

usage() - Static method in class org.apache.hadoop.chukwa.extraction.demux.DailyChukwaRecordRolling

usage() - Static method in class org.apache.hadoop.chukwa.extraction.demux.HourlyChukwaRecordRolling

user - Static variable in class org.apache.hadoop.chukwa.inputtools.log4j.Log4JMetricsContext

Util - Class in org.apache.hadoop.chukwa.extraction.demux.processor

Util() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.Util

uuid - Variable in class org.apache.hadoop.chukwa.datacollection.sender.ChukwaHttpSender.CommitListEntry

V

valueOf(String) - Static method in enum org.apache.hadoop.chukwa.extraction.demux.processor.mapper.ClientTraceProcessor.Locality

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.hadoop.chukwa.extraction.demux.processor.mapper.ClientTraceProcessor.Locality

Returns an array containing the constants of this enum type, in the order they are declared.

Views - Class in org.apache.hadoop.chukwa.hicc

Views() - Constructor for class org.apache.hadoop.chukwa.hicc.Views

viewsData - Variable in class org.apache.hadoop.chukwa.hicc.Views

ViewsTag - Class in org.apache.hadoop.chukwa.hicc

ViewsTag() - Constructor for class org.apache.hadoop.chukwa.hicc.ViewsTag

W

wait4Ack() - Method in class org.apache.hadoop.chukwa.datacollection.writer.ClientAck

waitFor() - Method in class org.apache.hadoop.chukwa.inputtools.plugin.ExecPlugin

WaitingQueue - Class in org.apache.hadoop.chukwa.datacollection.agent

WaitingQueue() - Constructor for class org.apache.hadoop.chukwa.datacollection.agent.WaitingQueue

WatchDog - Class in org.apache.hadoop.chukwa.util

WatchDog(String) - Constructor for class org.apache.hadoop.chukwa.util.WatchDog

WEEK - Static variable in class org.apache.hadoop.chukwa.database.DatabaseConfig

Workspace - Class in org.apache.hadoop.chukwa.hicc

Workspace() - Constructor for class org.apache.hadoop.chukwa.hicc.Workspace

write(DataOutput) - Method in interface org.apache.hadoop.chukwa.Chunk

write(DataOutput) - Method in class org.apache.hadoop.chukwa.ChunkImpl

writeCheckpoint() - Method in class org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

Called periodically to write checkpoints

WRITER_HDFS_FILESYSTEM_FIELD - Static variable in interface org.apache.hadoop.chukwa.extraction.CHUKWA_CONSTANT

WriterException - Exception in org.apache.hadoop.chukwa.datacollection.writer

WriterException() - Constructor for exception org.apache.hadoop.chukwa.datacollection.writer.WriterException

WriterException(String) - Constructor for exception org.apache.hadoop.chukwa.datacollection.writer.WriterException

WriterException(Throwable) - Constructor for exception org.apache.hadoop.chukwa.datacollection.writer.WriterException

WriterException(String, Throwable) - Constructor for exception org.apache.hadoop.chukwa.datacollection.writer.WriterException

writeTo(OutputStream) - Method in interface org.apache.hadoop.chukwa.datacollection.protocol.Protocol

X

XssFilter - Class in org.apache.hadoop.chukwa.util

XssFilter() - Constructor for class org.apache.hadoop.chukwa.util.XssFilter

XssFilter(HttpServletRequest) - Constructor for class org.apache.hadoop.chukwa.util.XssFilter

Y

YEAR - Static variable in class org.apache.hadoop.chukwa.database.DatabaseConfig

YWatch - Class in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

YWatch() - Constructor for class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.YWatch

YwatchInvalidEntry - Exception in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

YwatchInvalidEntry() - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.YwatchInvalidEntry

YwatchInvalidEntry(String) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.YwatchInvalidEntry

YwatchInvalidEntry(Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.YwatchInvalidEntry

YwatchInvalidEntry(String, Throwable) - Constructor for exception org.apache.hadoop.chukwa.extraction.demux.processor.mapper.YwatchInvalidEntry

A B C D E F G H I J K L M N O P Q R S T U V W X Y