T
- public class DataCopyTask<T extends PamDataUnit> extends OfflineTask<T>
Constructor and Description |
---|
DataCopyTask(PamDataBlock<T> pamDataBlock) |
Modifier and Type | Method and 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() |
java.lang.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).
|
boolean |
processDataUnit(T dataUnit)
Process a single data unit.
|
void |
setBinaryDataSource(BinaryDataSource binaryDataSource) |
void |
setSqlLogging(SQLLogging sqlLogging) |
addAffectedDataBlock, addRequiredDataBlock, callSettings, completeTask, deleteOldOutput, getAffectedDataBlock, getDataBlock, getNumAffectedDataBlocks, getNumRequiredDataBlocks, getOfflineTaskGroup, getRequiredDataBlock, hasSettings, isDoRun, prepareTask, setDoRun, setOfflineTaskGroup, setParentDataBlock
public DataCopyTask(PamDataBlock<T> pamDataBlock)
pamDataBlock
- public SQLLogging getSqlLogging()
public void setSqlLogging(SQLLogging sqlLogging)
sqlLogging
- the sqlLogging to setpublic BinaryDataSource getBinaryDataSource()
public void setBinaryDataSource(BinaryDataSource binaryDataSource)
binaryDataSource
- the binaryDataSource to setpublic java.lang.String getName()
getName
in class OfflineTask<T extends PamDataUnit>
public void newDataLoad(long startTime, long endTime, OfflineDataMapPoint mapPoint)
OfflineTask
newDataLoad
in class OfflineTask<T extends PamDataUnit>
startTime
- start time of loaded dataendTime
- end time of loaded datapublic boolean processDataUnit(T dataUnit)
OfflineTask
processDataUnit
in class OfflineTask<T extends PamDataUnit>
public boolean canRun()
OfflineTask
canRun
in class OfflineTask<T extends PamDataUnit>
public void loadedDataComplete()
OfflineTask
loadedDataComplete
in class OfflineTask<T extends PamDataUnit>