Package com.nt.udc.ndk.processor

Class FileInputProcessor

java.lang.Object

com.nt.udc.ndk.processor.DataSourceProcessor

com.nt.udc.ndk.processor.FileInputProcessor

All Implemented Interfaces:

CheckpointUserIfc, CheckpointUserSourceIfc, BaseDataProcessorIfc, DataProviderProcessorIfc, Runnable

public final class FileInputProcessor
extends DataSourceProcessor
implements CheckpointUserSourceIfc

Constructor Summary

Constructors

Constructor	Description
FileInputProcessor(PartitionedDCNode node, String newSuffix)

Method Summary

Modifier and Type	Method	Description
void	clearCheckpointData()
void	continueFromCheckpoint()
void	flushCheckpoint(BaseCheckpointData cp)
BaseCheckpointData	generateEmptyCheckpointData()
BaseCheckpointData	getCheckpointData()
String	getIdentifier()
void	initialize()
boolean	isProcessOver()
void	pauseForCheckpoint()
void	restoreCheckpoint(BaseCheckpointData cp)
void	run()
void	shutdown()

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

provideData, removeReceiver, setReceiver, startThread

Methods inherited from class java.lang.Object

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

Constructor Details

FileInputProcessor

public FileInputProcessor(PartitionedDCNode node,
 String newSuffix)
                   throws NodeStartException

Throws:

NodeStartException

Method Details

initialize

public void initialize()

Specified by:

initialize in interface BaseDataProcessorIfc

run

public void run()

Specified by:

run in interface Runnable

shutdown

public void shutdown()

Specified by:

shutdown in interface BaseDataProcessorIfc

Overrides:

shutdown in class DataSourceProcessor

isProcessOver

public boolean isProcessOver()

getIdentifier

public String getIdentifier()

Specified by:

getIdentifier in interface CheckpointUserIfc

generateEmptyCheckpointData

public BaseCheckpointData generateEmptyCheckpointData()

Specified by:

generateEmptyCheckpointData in interface CheckpointUserIfc

pauseForCheckpoint

public void pauseForCheckpoint()

Specified by:

pauseForCheckpoint in interface CheckpointUserSourceIfc

getCheckpointData

public BaseCheckpointData getCheckpointData()

Specified by:

getCheckpointData in interface CheckpointUserIfc

clearCheckpointData

public void clearCheckpointData()

Specified by:

clearCheckpointData in interface CheckpointUserIfc

continueFromCheckpoint

public void continueFromCheckpoint()

Specified by:

continueFromCheckpoint in interface CheckpointUserSourceIfc

flushCheckpoint

public void flushCheckpoint(BaseCheckpointData cp)

Specified by:

flushCheckpoint in interface CheckpointUserIfc

restoreCheckpoint

public void restoreCheckpoint(BaseCheckpointData cp)

Specified by:

restoreCheckpoint in interface CheckpointUserIfc