|
Oracle Fusion Middleware Java API Reference for Oracle Real-Time Decisions 11g Release 1 (11.1.1) E17787-02 |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object
com.sigmadynamics.sdo.support.BatchJobBase<T>
public abstract class BatchJobBase<T extends com.sigmadynamics.batch.InputRow>
Field Summary | |
---|---|
protected com.sigmadynamics.batch.BatchAgent |
agent |
protected java.lang.String |
batchID |
protected java.lang.String |
batchName |
protected int |
errorCountsFatalThreshold |
protected static InlineServiceLogger |
logger |
static java.lang.String |
PARAM_ERROR_COUNTS_FATAL_THESHOLD |
static java.lang.String |
PARAM_ROWS_BETWEEN_FLUSH_OUTPUTS |
static java.lang.String |
PARAM_ROWS_BETWEEN_STATUS_UPDATES |
static java.util.Properties |
paramDefaults |
static java.util.Properties |
paramDescriptions |
protected int |
restartCount |
protected int |
rowsBetweenFlushOutputs |
protected int |
rowsBetweenStatusUpdates |
protected BatchRequest |
startParameters |
Constructor Summary | |
---|---|
BatchJobBase() |
Method Summary | |
---|---|
com.sigmadynamics.batch.BatchAgent |
getAgent() |
java.lang.String |
getBatchID() |
java.lang.String |
getBatchName() |
java.util.Properties |
getDefaultPropertyValues() This is used by BatchJobBase at runtime to access the Properties object containing default values for its properties. |
int |
getErrorsCountFatalThreshold() Return how many non-fatal errors can be tolerated before the batch job should be terminated. |
protected InlineServiceLogger |
getLogger() |
int |
getRestartCount() |
int |
getRowsBetweenFlushOutputs() Return how many InputRows to process between calling the BatchJob's flushOutputs method. |
int |
getRowsBetweenStatusUpdates() Return how many rows to process between reporting status updates to the batch manager. |
void |
init(com.sigmadynamics.batch.BatchAgent agent, java.lang.String batchName, java.lang.String batchID, int restartCount, BatchRequest startParameters) Subclasses should call super.init(). |
void |
logDebug(java.lang.String msg) |
void |
logDebug(java.lang.String msg, java.lang.Object[] args) |
void |
logDebug(java.lang.String msg, java.lang.Object[] args, java.lang.Throwable t) |
void |
logDebug(java.lang.String msg, java.lang.Throwable t) |
void |
logError(java.lang.String msg) |
void |
logError(java.lang.String msg, java.lang.Object[] args) |
void |
logError(java.lang.String msg, java.lang.Object[] args, java.lang.Throwable t) |
void |
logError(java.lang.String key, java.lang.String msg) |
void |
logError(java.lang.String key, java.lang.String msg, java.lang.Object[] args) |
void |
logError(java.lang.String key, java.lang.String msg, java.lang.Object[] args, java.lang.Throwable t) |
void |
logError(java.lang.String key, java.lang.String msg, java.lang.Throwable t) |
void |
logError(java.lang.String msg, java.lang.Throwable t) |
void |
logError(java.lang.Throwable t) |
void |
logInfo(java.lang.String msg) |
void |
logInfo(java.lang.String msg, java.lang.Object[] args) |
void |
logInfo(java.lang.String msg, java.lang.Object[] args, java.lang.Throwable t) |
void |
logInfo(java.lang.String key, java.lang.String msg) |
void |
logInfo(java.lang.String key, java.lang.String msg, java.lang.Object[] args) |
void |
logInfo(java.lang.String key, java.lang.String msg, java.lang.Object[] args, java.lang.Throwable t) |
void |
logInfo(java.lang.String key, java.lang.String msg, java.lang.Throwable t) |
void |
logInfo(java.lang.String msg, java.lang.Throwable t) |
void |
logTrace(java.lang.String msg) |
void |
logTrace(java.lang.String msg, SDOInterface sdo) |
void |
logTrace(java.lang.String key, java.lang.String msg, java.lang.Object[] args) |
void |
logTrace(java.lang.String key, java.lang.String msg, java.lang.Object[] args, SDOInterface sdo) |
void |
logWarning(java.lang.String msg) |
void |
logWarning(java.lang.String msg, java.lang.Object[] args) |
void |
logWarning(java.lang.String msg, java.lang.Object[] args, java.lang.Throwable t) |
void |
logWarning(java.lang.String key, java.lang.String msg) |
void |
logWarning(java.lang.String key, java.lang.String msg, java.lang.Object[] args) |
void |
logWarning(java.lang.String key, java.lang.String msg, java.lang.Object[] args, java.lang.Throwable t) |
void |
logWarning(java.lang.String key, java.lang.String msg, java.lang.Throwable t) |
void |
logWarning(java.lang.String msg, java.lang.Throwable t) |
protected void |
setLogger(InlineServiceLogger logger) |
boolean |
shouldCountSessionCloseErrors() |
boolean |
traceEnabled() |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected static InlineServiceLogger logger
public static final java.lang.String PARAM_ERROR_COUNTS_FATAL_THESHOLD
public static final java.lang.String PARAM_ROWS_BETWEEN_STATUS_UPDATES
public static final java.lang.String PARAM_ROWS_BETWEEN_FLUSH_OUTPUTS
protected com.sigmadynamics.batch.BatchAgent agent
protected java.lang.String batchName
protected java.lang.String batchID
protected int restartCount
protected BatchRequest startParameters
protected int errorCountsFatalThreshold
protected int rowsBetweenStatusUpdates
protected int rowsBetweenFlushOutputs
public static java.util.Properties paramDefaults
public static java.util.Properties paramDescriptions
Constructor Detail |
---|
public BatchJobBase()
Method Detail |
---|
public void init(com.sigmadynamics.batch.BatchAgent agent, java.lang.String batchName, java.lang.String batchID, int restartCount, BatchRequest startParameters)
public java.util.Properties getDefaultPropertyValues()
If a subclass wants to change the default values of any properties used by the base class, it should clone the base class's paramDefaults
member, change the relevant values, and then override this method to return the cloned properties object to the base class. This allows multiple subclasses to have different default values for the same property name.
public com.sigmadynamics.batch.BatchAgent getAgent()
public java.lang.String getBatchName()
public java.lang.String getBatchID()
public int getRestartCount()
public int getErrorsCountFatalThreshold()
Returning 0 indicates the job should not be terminated for any number of non-fatal errors.
public int getRowsBetweenStatusUpdates()
Returning 0 indicates the job should not report status updates until it is finished.
public int getRowsBetweenFlushOutputs()
flushOutputs
method.
Returning 0 indicates the BatchJob's flushOutputs
method will be called only after the batch job finishes -- just before calling BatchJob.cleanup
, unless BatchJob.getRowsBetweenStatusUpdates
returns a positive number. If BatchJob.getRowsBetweenStatusUpdates
returns a positive number, BatchJob.fluserhOutputs
will also be called each time the BatchManager's status is updated.
public void logDebug(java.lang.String msg, java.lang.Object[] args, java.lang.Throwable t)
msg
-args
-t
-InlineServiceLogger.logDebug(java.lang.String, java.lang.Object[], java.lang.Throwable)
public void logDebug(java.lang.String msg, java.lang.Object[] args)
msg
-args
-InlineServiceLogger.logDebug(java.lang.String, java.lang.Object[])
public void logDebug(java.lang.String msg, java.lang.Throwable t)
msg
-t
-InlineServiceLogger.logDebug(java.lang.String, java.lang.Throwable)
public void logDebug(java.lang.String msg)
msg
-InlineServiceLogger.logDebug(java.lang.String)
public void logError(java.lang.String msg, java.lang.Object[] args, java.lang.Throwable t)
msg
-args
-t
-InlineServiceLogger.logError(java.lang.String, java.lang.Object[], java.lang.Throwable)
public void logError(java.lang.String msg, java.lang.Object[] args)
msg
-args
-InlineServiceLogger.logError(java.lang.String, java.lang.Object[])
public void logError(java.lang.String key, java.lang.String msg, java.lang.Object[] args, java.lang.Throwable t)
key
-msg
-args
-t
-InlineServiceLogger.logError(java.lang.String, java.lang.String, java.lang.Object[], java.lang.Throwable)
public void logError(java.lang.String key, java.lang.String msg, java.lang.Object[] args)
key
-msg
-args
-InlineServiceLogger.logError(java.lang.String, java.lang.String, java.lang.Object[])
public void logError(java.lang.String key, java.lang.String msg, java.lang.Throwable t)
key
-msg
-t
-InlineServiceLogger.logError(java.lang.String, java.lang.String, java.lang.Throwable)
public void logError(java.lang.String key, java.lang.String msg)
key
-msg
-InlineServiceLogger.logError(java.lang.String, java.lang.String)
public void logError(java.lang.String msg, java.lang.Throwable t)
msg
-t
-InlineServiceLogger.logError(java.lang.String, java.lang.Throwable)
public void logError(java.lang.String msg)
msg
-InlineServiceLogger.logError(java.lang.String)
public void logError(java.lang.Throwable t)
t
-InlineServiceLogger.logError(java.lang.Throwable)
public void logInfo(java.lang.String msg, java.lang.Object[] args, java.lang.Throwable t)
msg
-args
-t
-InlineServiceLogger.logInfo(java.lang.String, java.lang.Object[], java.lang.Throwable)
public void logInfo(java.lang.String msg, java.lang.Object[] args)
msg
-args
-InlineServiceLogger.logInfo(java.lang.String, java.lang.Object[])
public void logInfo(java.lang.String key, java.lang.String msg, java.lang.Object[] args, java.lang.Throwable t)
key
-msg
-args
-t
-InlineServiceLogger.logInfo(java.lang.String, java.lang.String, java.lang.Object[], java.lang.Throwable)
public void logInfo(java.lang.String key, java.lang.String msg, java.lang.Object[] args)
key
-msg
-args
-InlineServiceLogger.logInfo(java.lang.String, java.lang.String, java.lang.Object[])
public void logInfo(java.lang.String key, java.lang.String msg, java.lang.Throwable t)
key
-msg
-t
-InlineServiceLogger.logInfo(java.lang.String, java.lang.String, java.lang.Throwable)
public void logInfo(java.lang.String key, java.lang.String msg)
key
-msg
-InlineServiceLogger.logInfo(java.lang.String, java.lang.String)
public void logInfo(java.lang.String msg, java.lang.Throwable t)
msg
-t
-InlineServiceLogger.logInfo(java.lang.String, java.lang.Throwable)
public void logInfo(java.lang.String msg)
msg
-InlineServiceLogger.logInfo(java.lang.String)
public void logTrace(java.lang.String msg, SDOInterface sdo)
msg
-sdo
-InlineServiceLogger.logTrace(java.lang.String, com.sigmadynamics.sdo.interfaces.client.SDOInterface)
public void logTrace(java.lang.String key, java.lang.String msg, java.lang.Object[] args, SDOInterface sdo)
key
-msg
-args
-sdo
-InlineServiceLogger.logTrace(java.lang.String, java.lang.String, java.lang.Object[], com.sigmadynamics.sdo.interfaces.client.SDOInterface)
public void logTrace(java.lang.String key, java.lang.String msg, java.lang.Object[] args)
key
-msg
-args
-InlineServiceLogger.logTrace(java.lang.String, java.lang.String, java.lang.Object[])
public void logTrace(java.lang.String msg)
msg
-InlineServiceLogger.logTrace(java.lang.String)
public void logWarning(java.lang.String msg, java.lang.Object[] args, java.lang.Throwable t)
msg
-args
-t
-InlineServiceLogger.logWarning(java.lang.String, java.lang.Object[], java.lang.Throwable)
public void logWarning(java.lang.String msg, java.lang.Object[] args)
msg
-args
-InlineServiceLogger.logWarning(java.lang.String, java.lang.Object[])
public void logWarning(java.lang.String key, java.lang.String msg, java.lang.Object[] args, java.lang.Throwable t)
key
-msg
-args
-t
-InlineServiceLogger.logWarning(java.lang.String, java.lang.String, java.lang.Object[], java.lang.Throwable)
public void logWarning(java.lang.String key, java.lang.String msg, java.lang.Object[] args)
key
-msg
-args
-InlineServiceLogger.logWarning(java.lang.String, java.lang.String, java.lang.Object[])
public void logWarning(java.lang.String key, java.lang.String msg, java.lang.Throwable t)
key
-msg
-t
-InlineServiceLogger.logWarning(java.lang.String, java.lang.String, java.lang.Throwable)
public void logWarning(java.lang.String key, java.lang.String msg)
key
-msg
-InlineServiceLogger.logWarning(java.lang.String, java.lang.String)
public void logWarning(java.lang.String msg, java.lang.Throwable t)
msg
-t
-InlineServiceLogger.logWarning(java.lang.String, java.lang.Throwable)
public void logWarning(java.lang.String msg)
msg
-InlineServiceLogger.logWarning(java.lang.String)
public boolean traceEnabled()
InlineServiceLogger.traceEnabled()
protected InlineServiceLogger getLogger()
protected void setLogger(InlineServiceLogger logger)
public boolean shouldCountSessionCloseErrors()
|
Oracle Fusion Middleware Java API Reference for Oracle Real-Time Decisions 11g Release 1 (11.1.1) E17787-02 |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |