Package com.nt.udc.ndk.processor

Class NARInProcessor

java.lang.Object

com.nt.udc.ndk.processor.DataSourceProcessor

com.nt.udc.ndk.processor.NARInProcessor

All Implemented Interfaces:

BaseDataProcessorIfc, DataProviderProcessorIfc, Runnable

public final class NARInProcessor
extends DataSourceProcessor

Constructor Summary

Constructors

Constructor	Description
NARInProcessor(PartitionedDCNode node)

Method Summary

Modifier and Type	Method	Description
long	getRealNarsIn()	Gives the number of input records processed by the underlying NARFileManager object.
void	initialize()
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

NARInProcessor

public NARInProcessor(PartitionedDCNode node)

Method Details

initialize

public void initialize()

shutdown

public void shutdown()

Specified by:

shutdown in interface BaseDataProcessorIfc

Overrides:

shutdown in class DataSourceProcessor

run

public void run()

getRealNarsIn

public long getRealNarsIn()

Gives the number of input records processed by the underlying NARFileManager object.

Returns: