com.metasolv.nm.processor.MXAggregator

Class MXNarProvider

java.lang.Object

com.metasolv.nm.processor.MXAggregator.MXNarProvider

All Implemented Interfaces:

DataProviderIfc

public class MXNarProvider
extends java.lang.Object
implements DataProviderIfc

New interface between field processor threads and the NarInputProcessor.

Constructor Summary

Constructors

Constructor and Description
MXNarProvider(MXNarInputProcessor narIn, int index)

Method Summary

Modifier and Type	Method and Description
void	endRecordProcessing(DCFieldContainer dcfc)
DCFieldContainer[]	getBulkData() Only return an array of one NAR.
java.io.File	getCurrArchFile() Allows a DataReceiver to obtain the currently processing .arch file
DCFieldContainer	getData() Allows a DataReceiver to obtain the available data in a known format.
DCFieldContainer	getData(java.lang.String batch) Allows a DataReceiver to obtain the available data in a known format.
DataReceiverIfc	getDataReceiver() Deprecated.
java.lang.String	getProcessedArchFile() Allows a DataReceiver to obtain the last processed .arch file
boolean	isDataAvailable() Allows a DataReceiver to determine whether some data is available for processing
void	removeProcessedFile(java.io.File currArchFile) Allows a DataReceiver to remove .arch file once processed currArchFile - processed .arch file
void	setDataReceiver(DataReceiverIfc receiver) Deprecated.
void	setProcessedArchFile(java.lang.String file) Sets the processed .arch file absolute path
void	signalBatchCompletion(java.lang.String batch) Allows a DataReceiver to know that the nars under the specified batch are completed and handed over to the Data receiver
boolean	validOIMinorType() Allows a DataReceiver to check if Minor Type supported for disaster recovery

Methods inherited from class java.lang.Object

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

Constructor Detail

MXNarProvider

public MXNarProvider(MXNarInputProcessor narIn,
                     int index)

Method Detail

isDataAvailable

public boolean isDataAvailable()

Description copied from interface: DataProviderIfc

Allows a DataReceiver to determine whether some data is available for processing

Specified by:

isDataAvailable in interface DataProviderIfc

Returns:

true, if data is available

getData

public DCFieldContainer getData()

Description copied from interface: DataProviderIfc

Allows a DataReceiver to obtain the available data in a known format.

Specified by:

getData in interface DataProviderIfc

Returns:

DCFieldContainer object containing the data that is available for processing

getBulkData

public DCFieldContainer[] getBulkData()

Only return an array of one NAR.

Specified by:

getBulkData in interface DataProviderIfc

Returns:

DCFieldContainer object array, containing the data that is for processing

setDataReceiver

public void setDataReceiver(DataReceiverIfc receiver)

Deprecated.

Not used.

Specified by:

setDataReceiver in interface DataProviderIfc

Parameters:

receiver - Object which will obtain data from this DataProvider

getDataReceiver

public DataReceiverIfc getDataReceiver()

Deprecated.

Not used.

Specified by:

getDataReceiver in interface DataProviderIfc

Returns:

Object to which this DataProvider is sending data

endRecordProcessing

public void endRecordProcessing(DCFieldContainer dcfc)

getData

public DCFieldContainer getData(java.lang.String batch)

Description copied from interface: DataProviderIfc

Allows a DataReceiver to obtain the available data in a known format. batch - The nars read will be grouped under the specified batch

Specified by:

getData in interface DataProviderIfc

Returns:

DCFieldContainer object containing the data that is available for processing

signalBatchCompletion

public void signalBatchCompletion(java.lang.String batch)

Description copied from interface: DataProviderIfc

Allows a DataReceiver to know that the nars under the specified batch are completed and handed over to the Data receiver

Specified by:

signalBatchCompletion in interface DataProviderIfc

removeProcessedFile

public void removeProcessedFile(java.io.File currArchFile)

Description copied from interface: DataProviderIfc

Allows a DataReceiver to remove .arch file once processed currArchFile - processed .arch file

Specified by:

removeProcessedFile in interface DataProviderIfc

getProcessedArchFile

public java.lang.String getProcessedArchFile()

Description copied from interface: DataProviderIfc

Allows a DataReceiver to obtain the last processed .arch file

Specified by:

getProcessedArchFile in interface DataProviderIfc

Returns:

currently processing .arch file absolute path

setProcessedArchFile

public void setProcessedArchFile(java.lang.String file)

Description copied from interface: DataProviderIfc

Sets the processed .arch file absolute path

Specified by:

setProcessedArchFile in interface DataProviderIfc

Parameters:

file - absolute path of processed .arch file

getCurrArchFile

public java.io.File getCurrArchFile()

Description copied from interface: DataProviderIfc

Allows a DataReceiver to obtain the currently processing .arch file

Specified by:

getCurrArchFile in interface DataProviderIfc

Returns:

currently processing .arch file

validOIMinorType

public boolean validOIMinorType()

Description copied from interface: DataProviderIfc

Allows a DataReceiver to check if Minor Type supported for disaster recovery

Specified by:

validOIMinorType in interface DataProviderIfc

Returns:

true if valid