org.apache.hadoop.chukwa.dataloader

Class SocketDataLoader

java.lang.Object

org.apache.hadoop.chukwa.dataloader.SocketDataLoader

All Implemented Interfaces:

Runnable

public class SocketDataLoader
extends Object
implements Runnable

Socket Data Loader, also known as the SDL, is a framework for allowing direct access to log data under the Chukwa Collector in a safe and efficient manner. Subscribe to chukwaCollector.tee.port for data streaming. Defaults socket tee port is 9094.

Constructor Summary

Constructors

Constructor and Description
SocketDataLoader(String recordType)

Method Summary

Methods

Modifier and Type	Method and Description
Collection<Chunk>	read()
void	run()
boolean	running()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

SocketDataLoader

public SocketDataLoader(String recordType)

Method Detail

start

public void start()

read

public Collection<Chunk> read()
                       throws NoSuchElementException

Throws:

NoSuchElementException

stop

public void stop()

running

public boolean running()

run

public void run()

Specified by:

run in interface Runnable