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, java.awt.event.ActionListener, java.util.EventListener

public final class FileOutputProcessor
extends DataProcessor
implements CheckpointUserIfc, java.awt.event.ActionListener

Constructor Summary

Constructors

Constructor and Description
FileOutputProcessor(PartitionedDCNode node)

Method Summary

Methods

Modifier and Type	Method and Description
void	actionPerformed(java.awt.event.ActionEvent e)
void	clearCheckpointData()
void	flushCheckpoint(BaseCheckpointData cp)
BaseCheckpointData	generateEmptyCheckpointData()
BaseCheckpointData	getCheckpointData()
java.lang.String	getIdentifier()
void	initialize()
void	processData(java.lang.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 Detail

FileOutputProcessor

public FileOutputProcessor(PartitionedDCNode node)
                    throws NodeStartException

Throws:

NodeStartException

Method Detail

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 java.lang.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(java.lang.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(java.awt.event.ActionEvent e)

Specified by:

actionPerformed in interface java.awt.event.ActionListener