com.nt.udc.flexibleAggregator

Class FlexibleAggregatorFieldProcessor

java.lang.Object

com.nt.udc.ndk.node.DCFieldProcessor

com.nt.udc.ndk.node.NPLFieldProcessor

com.nt.udc.flexibleAggregator.FlexibleAggregatorFieldProcessor

All Implemented Interfaces:

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

public class FlexibleAggregatorFieldProcessor
extends NPLFieldProcessor

Field Summary

Fields

Modifier and Type	Field and Description
protected DiscardedStatisticsMonitorIfc	discardedCounts
protected FlexibleAggrKeyFactory[]	keyFactoryArray
protected FieldKey	mapChangeTime
protected FieldKey	mapDownlinkVolume
protected FieldKey	mapUplinkVolume
protected FlexibleNARKey[]	narKeyArray
protected static int	NODE_TYPE
protected FlexibleAggrTable[]	tableArray
protected FlexibleTableFlush[]	tableFlushArray
protected FlexibleTimerFlush[]	timerFlushArray
static int	TS_DAY
static int	TS_HOUR
static int	TS_MINUTE
static int	TS_MONTH
static int	TS_OFFSET_HOUR
static int	TS_OFFSET_MINUTE
static int	TS_SECOND
static int	TS_SIGN
static int	TS_YEAR Indices into the TimeStamp byte[].

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

currentState, currentTransactionId, fileLevelTransaction, freezeHelper, nplProgram, waitForInputLock

Constructor Summary

Constructors

Constructor and Description
FlexibleAggregatorFieldProcessor(java.lang.Class outputDataType, FlexibleAggregatorNode node, java.lang.String scratchDir, java.lang.String fileName, IDCMethodHandler methodHandler)

Method Summary

Modifier and Type	Method and Description
boolean	compareBytes(DCFieldContainer narA, DCFieldContainer narB, FieldKey attrId) Performs a simple byte comparison on the attribute in the two NARs.
FlexibleNARKey	createKey(int index, NAR nar) This will generate and return a key based on the record.
boolean	distributeTrafficVolumesPerDay(ListField trafficVolumes, NAR destContainer, java.util.List uplinkVolumeAttrs, java.util.List downlinkVolumeAttrs, ListField unprocessedVolumes, BytesField openingTime) This will distribute the traffic volume uplink and downlink volumes into appropriate daily bins according to the individual times.
byte[]	generateOpeningTimeFromTrafficVolume(java.util.List trafficVolumes) Will return the integer day of year corresponding to the first traffic volume.
boolean	getAndRemoveNAR(NAR nar, int index) This will remove the NAR entry from the table.
int	getCount(long tempKey, long tempKey1, long tempKey2, int index) Gets the Count
boolean	getNARKeepTimer(NAR nar, int index) This will remove a NAR but leave its timer.
protected void	init()
void	isAllKeyAttributesExists(NAR nar, int tableNumber)
int	populateIndividualTrafficVolume(java.util.Map trafficVolumeMap, DCFieldContainer destContainer, java.util.List uplinkVolumeIDs, java.util.List downlinkVolumeIDs, BytesField nextOpeningTime, int dayOfYearCheck) Will only populate the traffic volumes if they are for the same day as dayOfYearCheck, unless dayOfYearCheck < 1.
void	printTimer(NAR nar, int index) To be used in debugging only.
void	removeDeactivatedTimer(int index) This will remove a deactivated timer.
boolean	removeNAR(int index) This will remove a NAR entry from the table without returning the removed entry.
boolean	removeNARTimer(NAR nar, int index) This will remove the timer for a NAR from the timer table.
void	reset(long cleanup) Reset the Count
void	resetCount(long tempKey, long tempKey1, long tempKey2, int index)
void	setCount(long tempKey, long tempKey1, long tempKey2, int index) Sets the Count
void	shutdown() Performs all steps necessary to gracefully stop this FieldProcessor.
void	storeNAR(NAR nar, int index, boolean setTimer) This will generate a key and store the NAR in the table.
void	storeNARReusingTimer(NAR nar, int index) This will generate a key and store the NAR in the table with an old timer.

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, processData, processData, processFileData, processFileData, run, setbulkIOConfig, setBulkProcessing, setDataReceiver, setMultiThreadConfig, setNPLFileName, setPollForData, setProcessingData, setRunning, setShutdown, setShutdownOnError, setSleepTime, setTransactionID, 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

Field Detail

NODE_TYPE

protected static int NODE_TYPE

tableArray

protected FlexibleAggrTable[] tableArray

keyFactoryArray

protected FlexibleAggrKeyFactory[] keyFactoryArray

timerFlushArray

protected FlexibleTimerFlush[] timerFlushArray

tableFlushArray

protected FlexibleTableFlush[] tableFlushArray

narKeyArray

protected FlexibleNARKey[] narKeyArray

mapChangeTime

protected FieldKey mapChangeTime

mapUplinkVolume

protected FieldKey mapUplinkVolume

mapDownlinkVolume

protected FieldKey mapDownlinkVolume

discardedCounts

protected DiscardedStatisticsMonitorIfc discardedCounts

TS_YEAR

public static final int TS_YEAR

Indices into the TimeStamp byte[].

See Also:

Constant Field Values

TS_MONTH

public static final int TS_MONTH

See Also:

Constant Field Values

TS_DAY

public static final int TS_DAY

See Also:

Constant Field Values

TS_HOUR

public static final int TS_HOUR

See Also:

Constant Field Values

TS_MINUTE

public static final int TS_MINUTE

See Also:

Constant Field Values

TS_SECOND

public static final int TS_SECOND

See Also:

Constant Field Values

TS_SIGN

public static final int TS_SIGN

See Also:

Constant Field Values

TS_OFFSET_HOUR

public static final int TS_OFFSET_HOUR

See Also:

Constant Field Values

TS_OFFSET_MINUTE

public static final int TS_OFFSET_MINUTE

See Also:

Constant Field Values

Constructor Detail

FlexibleAggregatorFieldProcessor

public FlexibleAggregatorFieldProcessor(java.lang.Class outputDataType,
                                        FlexibleAggregatorNode node,
                                        java.lang.String scratchDir,
                                        java.lang.String fileName,
                                        IDCMethodHandler methodHandler)

Method Detail

init

protected void init()

isAllKeyAttributesExists

public void isAllKeyAttributesExists(NAR nar,
                                     int tableNumber)

shutdown

public void shutdown()

Description copied from class: NPLFieldProcessor

Performs all steps necessary to gracefully stop this FieldProcessor.

Overrides:

shutdown in class NPLFieldProcessor

createKey

public FlexibleNARKey createKey(int index,
                                NAR nar)

This will generate and return a key based on the record.

storeNAR

public void storeNAR(NAR nar,
                     int index,
                     boolean setTimer)

This will generate a key and store the NAR in the table.

printTimer

public void printTimer(NAR nar,
                       int index)

To be used in debugging only. Print the time that a NAR will be flushed from the aggregator

storeNARReusingTimer

public void storeNARReusingTimer(NAR nar,
                                 int index)

This will generate a key and store the NAR in the table with an old timer.

getNARKeepTimer

public boolean getNARKeepTimer(NAR nar,
                               int index)

This will remove a NAR but leave its timer.

removeNARTimer

public boolean removeNARTimer(NAR nar,
                              int index)

This will remove the timer for a NAR from the timer table. This should be used if the record was removed from the key table, but the timer value was left in the timer table, for example, if getNarSaveTimer was used.

getAndRemoveNAR

public boolean getAndRemoveNAR(NAR nar,
                               int index)

This will remove the NAR entry from the table.

removeNAR

public boolean removeNAR(int index)

This will remove a NAR entry from the table without returning the removed entry.

setCount

public void setCount(long tempKey,
                     long tempKey1,
                     long tempKey2,
                     int index)

Sets the Count

getCount

public int getCount(long tempKey,
                    long tempKey1,
                    long tempKey2,
                    int index)

Gets the Count

reset

public void reset(long cleanup)

Reset the Count

resetCount

public void resetCount(long tempKey,
                       long tempKey1,
                       long tempKey2,
                       int index)

removeDeactivatedTimer

public void removeDeactivatedTimer(int index)

This will remove a deactivated timer.

distributeTrafficVolumesPerDay

public boolean distributeTrafficVolumesPerDay(ListField trafficVolumes,
                                              NAR destContainer,
                                              java.util.List uplinkVolumeAttrs,
                                              java.util.List downlinkVolumeAttrs,
                                              ListField unprocessedVolumes,
                                              BytesField openingTime)

This will distribute the traffic volume uplink and downlink volumes into appropriate daily bins according to the individual times. If the traffic volumes goes past midnight, it will stop and return false. In this case, the volumes already processed for the previous day will be left processed. The list of traffic volumes will also have the processed volumes removed from the list. Only the unprocessed entries will remain. If no day change is detected, true is returned to indicate all traffic volumes have been processed.

populateIndividualTrafficVolume

public int populateIndividualTrafficVolume(java.util.Map trafficVolumeMap,
                                           DCFieldContainer destContainer,
                                           java.util.List uplinkVolumeIDs,
                                           java.util.List downlinkVolumeIDs,
                                           BytesField nextOpeningTime,
                                           int dayOfYearCheck)

Will only populate the traffic volumes if they are for the same day as dayOfYearCheck, unless dayOfYearCheck < 1. If the same day, that day of the year will be returned. If a different day, 0 will be returned. If no time is provided in the traffic volume map, -1 is returned.

generateOpeningTimeFromTrafficVolume

public byte[] generateOpeningTimeFromTrafficVolume(java.util.List trafficVolumes)

Will return the integer day of year corresponding to the first traffic volume.

compareBytes

public boolean compareBytes(DCFieldContainer narA,
                            DCFieldContainer narB,
                            FieldKey attrId)

Performs a simple byte comparison on the attribute in the two NARs.