com.nt.udc.ei.node.sol42

Class Sol42FieldProcessor

java.lang.Object

com.nt.udc.ndk.node.DCFieldProcessor

com.nt.udc.ndk.node.NPLFieldProcessor

com.nt.udc.ei.node.sol42.Sol42FieldProcessor

All Implemented Interfaces:

DataProviderIfc, DataReceiverIfc, FileDataProviderIfc, FileDataReceiverIfc, StateFreezable, java.lang.Runnable

public class Sol42FieldProcessor
extends NPLFieldProcessor

Field Summary

Fields inherited from class com.nt.udc.ndk.node.NPLFieldProcessor

currentState, currentTransactionId, fileLevelTransaction, freezeHelper, logger, nplProgram, waitForInputLock

Constructor Summary

Constructors

Constructor and Description
Sol42FieldProcessor(java.lang.Class outputDataType, LoggerIfc inLogger, java.lang.String scratchDir, java.lang.String fileName)
Sol42FieldProcessor(java.lang.Class outputDataType, LoggerIfc inLogger, java.lang.String scratchDir, java.lang.String fileName, boolean isFileLeveTranasction)
Sol42FieldProcessor(java.lang.Class outputDataType, LoggerIfc inLogger, java.lang.String scratchDir, java.lang.String fileName, IDCMethodHandler methodHandler)
Sol42FieldProcessor(java.lang.Class outputDataType, LoggerIfc inLogger, java.lang.String scratchDir, java.lang.String fileName, IDCMethodHandler methodHandler, boolean isFileLeveTranasction)

Method Summary

Methods

Modifier and Type	Method and Description
void	processData(DCFieldContainer[] inputData) Manipulates the set of data provided by its DataProvider
boolean	processFileData(DCFieldContainer[] inputData) This is just a dummy implementation, any field processor needing the file level transaction behavior should override this method and implement correct behavior.

Methods inherited from class com.nt.udc.ndk.node.NPLFieldProcessor

dataIsAvailable, freezeState, getBulkData, getConfigValue, getData, getExposedFields, getInputFields, getIntConfigValue, getLogger, getMethodHandler, getNPLFileName, getNPLProgram, getOutputFields, getPollForData, getSleepTime, handleProcessingException, handleProcessingException, handleProcessingException, handleRejectOfFile, isBulkProcessing, isDataAvailable, isFileLevelTransaction, isRejected, isRunning, isShutdown, isShutdownOnError, processData, processFileData, run, setBulkProcessing, setDataReceiver, setMultiThreadConfig, setNPLFileName, setPollForData, setProcessingData, setRunning, setShutdown, setShutdownOnError, setSleepTime, setTransactionID, shutdown, unfreezeState, writeToError, writeToError

Methods inherited from class com.nt.udc.ndk.node.DCFieldProcessor

fileDataIsAvailable, getDataProvider, getDataReceiver, getDiscardedCounter, getFileBulkData, getFileData, getFileDataProvider, getFileDataReceiver, getOutputType, isEndOfFile, isFileDataAvailable, isStartOfFile, openInputFile, processEndOfFileData, processRejectFile, processStartOfFileData, rejectFile, setDataProvider, setDiscardedCounter, setFileDataProvider, setFileDataReceiver, setOutputType

Methods inherited from class java.lang.Object

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

Constructor Detail

Sol42FieldProcessor

public Sol42FieldProcessor(java.lang.Class outputDataType,
                   LoggerIfc inLogger,
                   java.lang.String scratchDir,
                   java.lang.String fileName)
                    throws NodeProcessingException

Throws:

NodeProcessingException

Sol42FieldProcessor

public Sol42FieldProcessor(java.lang.Class outputDataType,
                   LoggerIfc inLogger,
                   java.lang.String scratchDir,
                   java.lang.String fileName,
                   boolean isFileLeveTranasction)
                    throws NodeProcessingException

Throws:

NodeProcessingException

Sol42FieldProcessor

public Sol42FieldProcessor(java.lang.Class outputDataType,
                   LoggerIfc inLogger,
                   java.lang.String scratchDir,
                   java.lang.String fileName,
                   IDCMethodHandler methodHandler)
                    throws NodeProcessingException

Throws:

NodeProcessingException

Sol42FieldProcessor

public Sol42FieldProcessor(java.lang.Class outputDataType,
                   LoggerIfc inLogger,
                   java.lang.String scratchDir,
                   java.lang.String fileName,
                   IDCMethodHandler methodHandler,
                   boolean isFileLeveTranasction)
                    throws NodeProcessingException

Throws:

NodeProcessingException

Method Detail

processData

public void processData(DCFieldContainer[] inputData)
                 throws NodeProcessingException

Description copied from interface: DataReceiverIfc

Manipulates the set of data provided by its DataProvider

Specified by:

processData in interface DataReceiverIfc

Overrides:

processData in class NPLFieldProcessor

Throws:

NodeProcessingException

processFileData

public boolean processFileData(DCFieldContainer[] inputData)
                        throws NodeProcessingException

Description copied from class: DCFieldProcessor

This is just a dummy implementation, any field processor needing the file level transaction behavior should override this method and implement correct behavior.

Specified by:

processFileData in interface FileDataReceiverIfc

Overrides:

processFileData in class NPLFieldProcessor

Returns:

true, if data is processed successfully

Throws:

NodeProcessingException