com.nt.udc.aggregator

Class AggregatorFieldProcessor

java.lang.Object

com.nt.udc.ndk.node.DCFieldProcessor

com.nt.udc.ndk.node.DeclNPLFieldProcessor

com.nt.udc.aggregator.AggregatorFieldProcessor

All Implemented Interfaces:

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

Direct Known Subclasses:

NARSelectorFieldProcessor

public class AggregatorFieldProcessor
extends DeclNPLFieldProcessor
implements java.lang.Runnable

This is the field processor for the aggregator, which contains pretty much all of the specific aggregation features.

Field Summary

Fields

Modifier and Type	Field and Description
protected AggrConfig	configHandler
static float	diffTimeSec
protected AggrCalcFields	fieldCalc
static int	fileNum
protected FlushConditions	flushConditions
protected TableFlush	flushHandler
protected GPRSAggregatorModule	gprsModule
protected int[]	init_fields
protected int[]	initFields
protected boolean	isSleeping
protected AggrKeyFactory	keyFactory
static int	narsProcessed
protected AggregatorNode	node
protected static int	NODE_TYPE
protected java.lang.String	nodeId
static float	nps
protected boolean	okToShutDown
protected long	processingInterval
protected AggrShifter	shifter
protected int	shutDownCheckDelay
protected boolean	shuttingDown
protected DCStreamHandler	streamHandler
protected AggrTable	tableHandler
protected TimeGrouper	timeGrouper
protected TimerFlush	timerFlushHandler
protected java.io.File	traceFile
protected AggrUtilityFields	utilFields
protected VOIPAggregatorModule	voipModule

Constructor Summary

Constructors

Constructor and Description
AggregatorFieldProcessor(java.lang.String fileName, AggregatorNode node, long processingInterval, java.io.File traceFile) Creates an aggregator field processor

Method Summary

Modifier and Type	Method and Description
protected NAR	createNewRecord(NAR incoming)
void	dataIsAvailable() Allows a DataProvider to indicate that some data is available for processing
protected void	getConfigData()
protected void	init()
boolean	isHealthy()
static void	main(java.lang.String[] args)
void	processData(DCFieldContainer incomingDCFC) Manipulates the data provided by its DataProvider
void	processData(DCFieldContainer[] incomingDCFCs) Manipulates the set of data provided by its DataProvider
void	run() This is the main run thread, containing the central processing loop.
void	shutdown() Shuts down the aggregator's field processor thread.

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

getBulkData, getData, getLogger, getNPLConfig, getNPLFileName, getNPLProgram, handleRejectOfFile, isDataAvailable, setNPLFileName

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

fileDataIsAvailable, getCurrArchFile, getData, getDataProvider, getDataReceiver, getDiscardedCounter, getFileBulkData, getFileData, getFileDataProvider, getFileDataReceiver, getOutputType, getPollForData, getProcessedArchFile, isEndOfFile, isFileDataAvailable, isStartOfFile, openInputFile, processEndOfFileData, processFileData, processFileData, processRejectFile, processStartOfFileData, rejectFile, removeProcessedFile, setbulkIOConfig, setBulkProcessing, setDataProvider, setDataReceiver, setDiscardedCounter, setFileDataProvider, setFileDataReceiver, setMultiThreadConfig, setOutputType, setPollForData, setProcessedArchFile, setTransactionID, signalBatchCompletion, validOIMinorType

Methods inherited from class java.lang.Object

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

Field Detail

okToShutDown

protected boolean okToShutDown

shuttingDown

protected boolean shuttingDown

isSleeping

protected boolean isSleeping

shutDownCheckDelay

protected int shutDownCheckDelay

initFields

protected int[] initFields

configHandler

protected AggrConfig configHandler

streamHandler

protected DCStreamHandler streamHandler

nodeId

protected java.lang.String nodeId

node

protected AggregatorNode node

processingInterval

protected long processingInterval

traceFile

protected java.io.File traceFile

init_fields

protected int[] init_fields

NODE_TYPE

protected static int NODE_TYPE

tableHandler

protected AggrTable tableHandler

keyFactory

protected AggrKeyFactory keyFactory

flushHandler

protected TableFlush flushHandler

timerFlushHandler

protected TimerFlush timerFlushHandler

flushConditions

protected FlushConditions flushConditions

fieldCalc

protected AggrCalcFields fieldCalc

shifter

protected AggrShifter shifter

timeGrouper

protected TimeGrouper timeGrouper

utilFields

protected AggrUtilityFields utilFields

gprsModule

protected GPRSAggregatorModule gprsModule

voipModule

protected VOIPAggregatorModule voipModule

fileNum

public static int fileNum

narsProcessed

public static int narsProcessed

diffTimeSec

public static float diffTimeSec

nps

public static float nps

Constructor Detail

AggregatorFieldProcessor

public AggregatorFieldProcessor(java.lang.String fileName,
                                AggregatorNode node,
                                long processingInterval,
                                java.io.File traceFile)

Creates an aggregator field processor

Method Detail

init

protected void init()

getConfigData

protected void getConfigData()

shutdown

public void shutdown()

Shuts down the aggregator's field processor thread.

Specified by:

shutdown in class DeclNPLFieldProcessor

run

public void run()

This is the main run thread, containing the central processing loop.

Specified by:

run in interface java.lang.Runnable

Specified by:

run in class DeclNPLFieldProcessor

createNewRecord

protected NAR createNewRecord(NAR incoming)

dataIsAvailable

public void dataIsAvailable()

Description copied from interface: DataReceiverIfc

Allows a DataProvider to indicate that some data is available for processing

Specified by:

dataIsAvailable in interface DataReceiverIfc

Specified by:

dataIsAvailable in class DeclNPLFieldProcessor

processData

public void processData(DCFieldContainer incomingDCFC)

Description copied from interface: DataReceiverIfc

Manipulates the data provided by its DataProvider

Specified by:

processData in interface DataReceiverIfc

Specified by:

processData in class DeclNPLFieldProcessor

processData

public void processData(DCFieldContainer[] incomingDCFCs)

Description copied from interface: DataReceiverIfc

Manipulates the set of data provided by its DataProvider

Specified by:

processData in interface DataReceiverIfc

Specified by:

processData in class DeclNPLFieldProcessor

main

public static void main(java.lang.String[] args)

isHealthy

public boolean isHealthy()