Package com.nt.udc.ndk.processor

Class FileOutputProcessor

java.lang.Object

com.nt.udc.ndk.processor.DataProcessor

com.nt.udc.ndk.processor.FileOutputProcessor

All Implemented Interfaces:

CheckpointUserIfc, BaseDataProcessorIfc, DataProviderProcessorIfc, DataReceiverProcessorIfc, ActionListener, EventListener

public final class FileOutputProcessor
extends DataProcessor
implements CheckpointUserIfc, ActionListener

Constructor Summary

Constructors

Constructor	Description
FileOutputProcessor(PartitionedDCNode node)

Method Summary

Modifier and Type	Method	Description
void	actionPerformed(ActionEvent e)
void	clearCheckpointData()
void	flushCheckpoint(BaseCheckpointData cp)
BaseCheckpointData	generateEmptyCheckpointData()
BaseCheckpointData	getCheckpointData()
String	getIdentifier()
void	initialize()
void	processData(Object dataItem)	Implement this to perform work on incoming data.
void	restoreCheckpoint(BaseCheckpointData cp)
void	shutdown()

Methods inherited from class com.nt.udc.ndk.processor.DataProcessor

provideData, removeProvider, removeReceiver, setProvider, setReceiver

Methods inherited from class java.lang.Object

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

Constructor Details

FileOutputProcessor

public FileOutputProcessor(PartitionedDCNode node)
                    throws NodeStartException

Throws:

NodeStartException

Method Details

initialize

public void initialize()

Specified by:

initialize in interface BaseDataProcessorIfc

shutdown

public void shutdown()

Specified by:

shutdown in interface BaseDataProcessorIfc

Overrides:

shutdown in class DataProcessor

getIdentifier

public String getIdentifier()

Specified by:

getIdentifier in interface CheckpointUserIfc

generateEmptyCheckpointData

public BaseCheckpointData generateEmptyCheckpointData()

Specified by:

generateEmptyCheckpointData in interface CheckpointUserIfc

getCheckpointData

public BaseCheckpointData getCheckpointData()

Specified by:

getCheckpointData in interface CheckpointUserIfc

clearCheckpointData

public void clearCheckpointData()

Specified by:

clearCheckpointData in interface CheckpointUserIfc

flushCheckpoint

public void flushCheckpoint(BaseCheckpointData cp)

Specified by:

flushCheckpoint in interface CheckpointUserIfc

restoreCheckpoint

public void restoreCheckpoint(BaseCheckpointData cp)

Specified by:

restoreCheckpoint in interface CheckpointUserIfc

processData

public void processData(Object dataItem)

Description copied from interface: DataReceiverProcessorIfc

Implement this to perform work on incoming data.

Specified by:

processData in interface DataReceiverProcessorIfc

actionPerformed

public void actionPerformed(ActionEvent e)

Specified by:

actionPerformed in interface ActionListener