org.dice_research.ldcbench.nodes.rabbit

Class DataHandler

java.lang.Object

org.dice_research.ldcbench.nodes.rabbit.DataHandler

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

GraphHandler

public class DataHandler
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field and Description
protected int	errorCount
private static org.slf4j.Logger	LOGGER
protected String[]	receivedFiles
protected String	receiveOutputDir
protected org.hobbit.core.rabbit.SimpleFileReceiver	receiver

Constructor Summary

Constructors

Constructor and Description
DataHandler(org.hobbit.core.rabbit.SimpleFileReceiver receiver)

Method Summary

Modifier and Type	Method and Description
boolean	encounteredError()
int	getErrorCount()
String[]	getReceivedFiles()
private static String	getTempDir()
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

receiver

protected org.hobbit.core.rabbit.SimpleFileReceiver receiver

errorCount

protected int errorCount

receiveOutputDir

protected String receiveOutputDir

receivedFiles

protected String[] receivedFiles

Constructor Detail

DataHandler

public DataHandler(org.hobbit.core.rabbit.SimpleFileReceiver receiver)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

getTempDir

private static String getTempDir()
                          throws IOException

Throws:

IOException

getErrorCount

public int getErrorCount()

encounteredError

public boolean encounteredError()

getReceivedFiles

public String[] getReceivedFiles()