org.apache.hadoop.chukwa.datacollection

Class DataFactory

java.lang.Object

org.apache.hadoop.chukwa.datacollection.DataFactory

public class DataFactory
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static DataFactory	dataFactory

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

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

Field Detail

dataFactory

protected static final DataFactory dataFactory

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 -

filename -

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