Package offlineProcessing

Class DataCopyTask<T extends PamDataUnit>

java.lang.Object

offlineProcessing.OfflineTask<T>

offlineProcessing.DataCopyTask<T>

Type Parameters:

T -

Direct Known Subclasses:

DifarDataCopyTask

public class DataCopyTask<T extends PamDataUnit>
extends OfflineTask<T>

Generic class for copying data from binary data files to database files. This will generally use the default SqlLogging and binaryDataSources which are already set in the datablock so copy data from the binary to the database.

Author:

Doug Gillespie

Constructor Summary

Constructors

Constructor	Description
DataCopyTask(PamDataBlock<T> pamDataBlock)

Method Summary

Modifier and Type	Method	Description
boolean	canRun()	can the task be run ? This will generally be true, but may be false if the task is dependent on some other module which may not be present.
BinaryDataSource	getBinaryDataSource()
String	getName()
SQLLogging	getSqlLogging()
void	loadedDataComplete()	Called when processing of loaded data, or each map point worth of data, is complete.
void	newDataLoad(long startTime, long endTime, OfflineDataMapPoint mapPoint)	Called when new data are loaded for offline processing (or once at the start of processing loaded data).
void	prepareTask()	Called at the start of the thread which executes this task.
boolean	processDataUnit(T dataUnit)	Process a single data unit.
void	setBinaryDataSource(BinaryDataSource binaryDataSource)
void	setSqlLogging(SQLLogging sqlLogging)

Methods inherited from class offlineProcessing.OfflineTask

addAffectedDataBlock, addRequiredDataBlock, addRequiredDataBlock, addRequiredDataBlock, callSettings, completeTask, deleteOldData, deleteOldOutput, getAffectedBlocksList, getAffectedDataBlock, getDataBlock, getLongName, getNumAffectedDataBlocks, getNumRequiredDataBlocks, getOfflineTaskGroup, getRequiredDataBlock, getTaskControlledUnit, getUnitName, getUnitType, hasSettings, isDoRun, setDoRun, setOfflineTaskGroup, setParentDataBlock

Methods inherited from class java.lang.Object

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

Constructor Details

DataCopyTask

public DataCopyTask(PamDataBlock<T> pamDataBlock)

Parameters:

pamDataBlock -

Method Details

getSqlLogging

public SQLLogging getSqlLogging()

Returns:

the sqlLogging

setSqlLogging

public void setSqlLogging(SQLLogging sqlLogging)

Parameters:

sqlLogging - the sqlLogging to set

getBinaryDataSource

public BinaryDataSource getBinaryDataSource()

Returns:

the binaryDataSource

setBinaryDataSource

public void setBinaryDataSource(BinaryDataSource binaryDataSource)

Parameters:

binaryDataSource - the binaryDataSource to set

getName

public String getName()

Specified by:

getName in class OfflineTask<T extends PamDataUnit>

Returns:

a name for the task, to be displayed in the dialog.

newDataLoad

public void newDataLoad(long startTime,
 long endTime,
 OfflineDataMapPoint mapPoint)

Description copied from class: OfflineTask

Called when new data are loaded for offline processing (or once at the start of processing loaded data).

Specified by:

newDataLoad in class OfflineTask<T extends PamDataUnit>

Parameters:

startTime - start time of loaded data

endTime - end time of loaded data

prepareTask

public void prepareTask()

Description copied from class: OfflineTask

Called at the start of the thread which executes this task.

Overrides:

prepareTask in class OfflineTask<T extends PamDataUnit>

processDataUnit

public boolean processDataUnit(T dataUnit)

Description copied from class: OfflineTask

Process a single data unit.

Specified by:

processDataUnit in class OfflineTask<T extends PamDataUnit>

Returns:

true if the data unit has changed in some way so that it will need re-writing to it's binary file or database.

canRun

public boolean canRun()

Description copied from class: OfflineTask

can the task be run ? This will generally be true, but may be false if the task is dependent on some other module which may not be present.

Overrides:

canRun in class OfflineTask<T extends PamDataUnit>

Returns:

true if it's possible to run the task.

loadedDataComplete

public void loadedDataComplete()

Description copied from class: OfflineTask

Called when processing of loaded data, or each map point worth of data, is complete.

Specified by:

loadedDataComplete in class OfflineTask<T extends PamDataUnit>