org.apache.hadoop.chukwa.datacollection.sender
Interface ChukwaSender

All Known Implementing Classes:

AsyncAckSender, ChukwaHttpSender

public interface ChukwaSender

Method Summary

List<ChukwaHttpSender.CommitListEntry>	send(List<Chunk> chunksToSend)
void	setCollectors(Iterator<String> collectors)
void	stop()

Method Detail

send

List<ChukwaHttpSender.CommitListEntry> send(List<Chunk> chunksToSend)
                                            throws InterruptedException,
                                                   IOException

Parameters:

chunksToSend - a list of chunks to commit

Returns:

the list of committed chunks

Throws:

InterruptedException - if interrupted while trying to send

IOException

setCollectors

void setCollectors(Iterator<String> collectors)

stop

void stop()