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, java.lang.Runnable

public final class NARInProcessor
extends DataSourceProcessor

Constructor Summary

Constructors

Constructor and Description
NARInProcessor(PartitionedDCNode node)

Method Summary

Methods

Modifier and Type	Method and 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 Detail

NARInProcessor

public NARInProcessor(PartitionedDCNode node)

Method Detail

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: