|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.util.Observable
toxTree.io.batch.BatchProcessing
public abstract class BatchProcessing
Accessing & serializing Array: Throwing exception in jre6 while it works in jre5 http://bugs.sun.com/bugdatabase/view_bug.do?bug_id=6554519 An abstract class to support Batch processing with several fail safe options
Field Summary | |
---|---|
protected java.io.File |
configFile
|
protected java.util.Date |
dateCreated
|
protected java.util.Date |
dateLastSaved
|
protected boolean |
deleteConfigOnSuccess
|
protected FileState |
inputFile
|
protected static TTLogger |
logger
|
protected static java.lang.String |
MSG_CANTCREATEFILE
|
protected static java.lang.String |
MSG_ERRORCOUNTING
|
protected static java.lang.String |
MSG_ERRORSAVE
|
protected static java.lang.String |
MSG_FILEDONOTEXISTS
|
protected static java.lang.String |
MSG_OPEN
|
protected static java.lang.String |
MSG_UNSUPPORTEDFORMAT
|
protected FileState |
outputFile
|
protected int |
saveStateFrequency
|
int |
status
|
static int |
STATUS_ABORTED
|
static int |
STATUS_FINISHED
|
static int |
STATUS_NOTINITIALIZED
|
static int |
STATUS_NOTSTARTED
|
static int |
STATUS_PAUSED
|
static int |
STATUS_RUNNING
|
protected static java.lang.String[] |
statusMsg
|
protected java.lang.String |
tmpDir
|
Constructor Summary | |
---|---|
BatchProcessing()
Creates empty BatchProcessing it should be configured prior to use |
|
BatchProcessing(java.io.File input,
java.io.File output)
Creates BatchProcessing given input and output file names |
|
BatchProcessing(java.lang.String input,
java.lang.String output)
Creates BatchProcessing given input and output file names |
Method Summary | |
---|---|
void |
cancel()
|
void |
close()
|
java.io.File |
createConfigFile()
|
void |
createOutputFile()
|
boolean |
equals(java.lang.Object obj)
|
java.io.File |
getConfigFile()
Where to store batchprocessing configuration itself |
java.util.Date |
getDateCreated()
|
java.util.Date |
getDateLastProcessed()
|
FileState |
getInputFile()
|
FileState |
getOutputFile()
|
long |
getReadRecordsCount()
Returns the number of records read from the input file |
int |
getSaveStateFrequency()
BatchProcessing saves its state on each saveStateFrequency records |
int |
getStatus()
|
java.lang.String |
getTempDir()
|
long |
getWrittenRecordsCount()
Returns the number of records written to the output file |
boolean |
isCancelled()
|
boolean |
isPaused()
|
boolean |
isRunning()
|
boolean |
isStatus(int status)
|
void |
loadConfig()
|
void |
openInputFile()
|
void |
pause()
|
void |
saveConfig()
|
void |
saveConfig(java.io.OutputStream out)
|
void |
setConfigFile(java.io.File configFile)
|
void |
setSaveStateFrequency(int saveStateFrequency)
BatchProcessing saves its state on each saveStateFrequency records |
protected void |
setStatus(int status)
|
void |
start()
|
java.lang.String |
toString()
|
Methods inherited from class java.util.Observable |
---|
addObserver, clearChanged, countObservers, deleteObserver, deleteObservers, hasChanged, notifyObservers, notifyObservers, setChanged |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface toxTree.io.batch.IBatchProcessing |
---|
closeInputFile, closeOutputFile, hasNextRecord, processRecord, readRecord, writeRecord |
Field Detail |
---|
protected int saveStateFrequency
protected FileState inputFile
protected FileState outputFile
protected java.util.Date dateCreated
protected java.util.Date dateLastSaved
protected transient java.io.File configFile
protected transient java.lang.String tmpDir
protected transient boolean deleteConfigOnSuccess
protected static transient java.lang.String MSG_FILEDONOTEXISTS
protected static transient java.lang.String MSG_CANTCREATEFILE
protected static transient java.lang.String MSG_OPEN
protected static transient java.lang.String MSG_UNSUPPORTEDFORMAT
protected static transient java.lang.String MSG_ERRORSAVE
protected static transient java.lang.String MSG_ERRORCOUNTING
protected static transient TTLogger logger
protected static transient java.lang.String[] statusMsg
public static final transient int STATUS_NOTSTARTED
public static final transient int STATUS_RUNNING
public static final transient int STATUS_FINISHED
public static final transient int STATUS_PAUSED
public static final transient int STATUS_ABORTED
public static final transient int STATUS_NOTINITIALIZED
public int status
Constructor Detail |
---|
public BatchProcessing()
public BatchProcessing(java.lang.String input, java.lang.String output) throws BatchProcessingException
input
- Input filename; should existsoutput
- Results (output) filename ; deleted if exists
BatchProcessingException
- -
if input file do not exists - if output file can't be deleted
and a new one created; - on any IOExceptionpublic BatchProcessing(java.io.File input, java.io.File output) throws BatchProcessingException
input
- Input filename; should existsoutput
- Results (output) filename ; deleted if exists
BatchProcessingException
- -
if input file do not exists - if output file can't be deleted
and a new one created; - on any IOExceptionMethod Detail |
---|
public void openInputFile() throws BatchProcessingException
openInputFile
in interface IBatchProcessing
BatchProcessingException
public void createOutputFile() throws BatchProcessingException
createOutputFile
in interface IBatchProcessing
BatchProcessingException
public void start() throws BatchProcessingException
start
in interface IBatchProcessing
BatchProcessingException
public void close() throws BatchProcessingException
close
in interface IBatchProcessing
BatchProcessingException
public void pause() throws BatchProcessingException
pause
in interface IBatchProcessing
BatchProcessingException
public void cancel() throws BatchProcessingException
cancel
in interface IBatchProcessing
BatchProcessingException
public void saveConfig() throws BatchProcessingException
saveConfig
in interface IBatchProcessing
BatchProcessingException
public void saveConfig(java.io.OutputStream out) throws BatchProcessingException
BatchProcessingException
public void loadConfig() throws BatchProcessingException
loadConfig
in interface IBatchProcessing
BatchProcessingException
public boolean isStatus(int status)
protected void setStatus(int status)
status
- The status to set.public java.lang.String toString()
toString
in class java.lang.Object
public int getSaveStateFrequency()
public void setSaveStateFrequency(int saveStateFrequency)
saveStateFrequency
- The saveStateFrequency to set.public java.lang.String getTempDir()
public java.io.File createConfigFile()
public java.io.File getConfigFile()
public void setConfigFile(java.io.File configFile)
setConfigFile
in interface IBatchProcessing
configFile
- The configFile to set.public boolean equals(java.lang.Object obj)
equals
in class java.lang.Object
public int getStatus()
public long getReadRecordsCount()
getReadRecordsCount
in interface IBatchProcessing
public long getWrittenRecordsCount()
getWrittenRecordsCount
in interface IBatchProcessing
public FileState getInputFile()
public FileState getOutputFile()
public boolean isRunning()
isRunning
in interface IBatchProcessing
public boolean isPaused()
isPaused
in interface IBatchProcessing
public boolean isCancelled()
isCancelled
in interface IBatchProcessing
public java.util.Date getDateCreated()
getDateCreated
in interface IBatchProcessing
Date
when batch job was first createdpublic java.util.Date getDateLastProcessed()
getDateLastProcessed
in interface IBatchProcessing
Date
when batch job was processed last
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |