public class DataFactory extends Object
Modifier and Type | Field and Description |
---|---|
protected static DataFactory |
dataFactory |
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) |
protected static final DataFactory dataFactory
public static DataFactory getInstance()
public ChunkQueue getEventQueue()
public void put(Chunk c) throws InterruptedException
InterruptedException
public ChunkQueue createEventQueue()
public String getDefaultTags()
public void setDefaultTags(String tags)
public void addDefaultTag(String tag)
public Iterator<String> getCollectorURLs(org.apache.hadoop.conf.Configuration conf, String filename) throws IOException
conf
- filename
- IOException
- on other errorpublic Iterator<String> getCollectorURLs(org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
Copyright © 2015 Apache Software Foundation. All Rights Reserved.