org.apache.hadoop.chukwa.datacollection

Class DataFactory

java.lang.Object

org.apache.hadoop.chukwa.datacollection.DataFactory

public class DataFactory
extends Object

Method Summary

Methods

Modifier and Type	Method and Description
void	addDefaultTag(String tag)
ChunkQueue	createEventQueue()
Iterator<String>	getCollectorURLs(org.apache.hadoop.conf.Configuration conf)
Iterator<String>	getCollectorURLs(org.apache.hadoop.conf.Configuration conf, String filename)
String	getDefaultTags()
ChunkQueue	getEventQueue()
static DataFactory	getInstance()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getInstance

public static DataFactory getInstance()

getEventQueue

public ChunkQueue getEventQueue()

createEventQueue

public ChunkQueue createEventQueue()

getDefaultTags

public String getDefaultTags()

addDefaultTag

public void addDefaultTag(String tag)

getCollectorURLs

public Iterator<String> getCollectorURLs(org.apache.hadoop.conf.Configuration conf,
                                String filename)
                                  throws IOException

Returns:

empty list if file does not exist

Throws:

IOException - on other error

getCollectorURLs

public Iterator<String> getCollectorURLs(org.apache.hadoop.conf.Configuration conf)
                                  throws IOException

Throws:

IOException