org.apache.hadoop.chukwa.datacollection

Class DataFactory

java.lang.Object

org.apache.hadoop.chukwa.datacollection.DataFactory

public class DataFactory
extends Object

Method Summary

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()
void	put(Chunk c)
void	setDefaultTags(String tags)

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static DataFactory getInstance()

getEventQueue

public ChunkQueue getEventQueue()

put

public void put(Chunk c)
         throws InterruptedException

Throws:

InterruptedException

createEventQueue

public ChunkQueue createEventQueue()

getDefaultTags

public String getDefaultTags()

setDefaultTags

public void setDefaultTags(String tags)

addDefaultTag

public void addDefaultTag(String tag)

getCollectorURLs

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

Parameters:

conf - is Chukwa configuration

filename - is collector list

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