com.nt.udc.oi.node.jdbc

Class JDBCOIFieldProcessor

java.lang.Object

com.nt.udc.ndk.node.DCFieldProcessor

com.nt.udc.ndk.node.NPLFieldProcessor

com.nt.udc.oi.node.jdbc.JDBCOIFieldProcessor

All Implemented Interfaces:

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

public class JDBCOIFieldProcessor
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
JDBCOIFieldProcessor(DCNode node, int batchSize, java.lang.Class outputDataType, LoggerIfc inLogger, java.lang.String scratchDir, java.lang.String fileName)

Method Summary

Modifier and Type	Method and Description
DCFieldContainer[]	getBulkData() Allows a DataReceiver to obtain the available data in a known format.

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

dataIsAvailable, freezeState, getConfigValue, getData, getExposedFields, getInputFields, getIntConfigValue, getLogger, getMethodHandler, getNPLFileName, getNPLProgram, getOutputFields, getPollForData, getSleepTime, handleProcessingException, handleProcessingException, handleProcessingException, handleRejectOfFile, isBulkProcessing, isDataAvailable, isFileLevelTransaction, isRejected, isRunning, isShutdown, isShutdownOnError, processData, processData, processData, processFileData, processFileData, run, setbulkIOConfig, 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, getCurrArchFile, getData, getDataProvider, getDataReceiver, getDiscardedCounter, getFileBulkData, getFileData, getFileDataProvider, getFileDataReceiver, getOutputType, getProcessedArchFile, isEndOfFile, isFileDataAvailable, isStartOfFile, openInputFile, processEndOfFileData, processRejectFile, processStartOfFileData, rejectFile, removeProcessedFile, setDataProvider, setDiscardedCounter, setFileDataProvider, setFileDataReceiver, setOutputType, setProcessedArchFile, signalBatchCompletion, validOIMinorType

Methods inherited from class java.lang.Object

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

Constructor Detail

JDBCOIFieldProcessor

public JDBCOIFieldProcessor(DCNode node,
                            int batchSize,
                            java.lang.Class outputDataType,
                            LoggerIfc inLogger,
                            java.lang.String scratchDir,
                            java.lang.String fileName)
                     throws NodeProcessingException

Throws:

NodeProcessingException

Method Detail

getBulkData

public DCFieldContainer[] getBulkData()

Description copied from interface: DataProviderIfc

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

Specified by:

getBulkData in interface DataProviderIfc

Overrides:

getBulkData in class NPLFieldProcessor

Returns:

DCFieldContainer object array, containing the data that is for processing