public abstract class AbstractSpringBatchLoader extends BaseLoader implements Loader
BaseLoader.DoConversion
ASYNC_OPTION, FAIL_ON_ERROR_OPTION, inUse, LOADER_POST_PROCESSOR_OPTION, LOADER_PREFERENCE_FILE_OPTION, MANIFEST_FILE_OPTION, SUPPLEMENT_OPTION
Modifier | Constructor and Description |
---|---|
protected |
AbstractSpringBatchLoader() |
Modifier and Type | Method and Description |
---|---|
protected org.springframework.batch.core.JobParameters |
buildJobParameters(java.util.Properties props)
Builds the job parameters.
|
org.springframework.batch.core.JobExecution |
getJobExecution() |
URNVersionPair[] |
getLoadedCodingSchemes() |
protected abstract URNVersionPair[] |
getLoadedCodingSchemes(org.springframework.context.ApplicationContext context) |
static java.net.URI |
getURIFromPath(java.lang.String path) |
protected void |
launchJob(java.util.Properties connectionProperties,
java.lang.String jobConfigFile,
java.lang.String jobName)
Launch job.
|
protected void |
printJobProperties(java.util.Properties jobProperties) |
protected void |
printStartLogInfo(java.util.Properties connectionProperties,
java.lang.String jobConfigFile,
java.lang.String jobName) |
protected ProcessState |
processStateConverter(org.springframework.batch.core.BatchStatus status) |
void |
setLoadedCodingSchemes(URNVersionPair[] loadedCodingSchemes) |
addBooleanOptionValue, baseLoad, buildRootNode, clearLog, constructVersionPairsFromCodingSchemes, createCachingMessageDirectorIF, createDefaultInserter, createDefaultInserter, declareAllowedOptions, doesOptionExist, doIndex, doLoad, doPostProcessing, doRegister, doTransitiveAndIndex, doTransitiveTable, getAbsoluteCodingSchemeVersionReferenceFromOptionString, getCodingSchemeManifest, getCodingSchemeManifestURI, getCodingSchemeReferences, getDescription, getLoaderPreferences, getLog, getLogger, getManifestUtil, getMessageDirector, getName, getOntologyFormat, getOptions, getPostProcessor, getProvider, getResourceUri, getStatus, getStringFromURI, getVersion, isDoApplyPostLoadManifest, isDoComputeTransitiveClosure, isDoIndexing, isDoRegister, isDoRemoveOnFailure, isInUse, load, lock, persistCodingSchemeToDatabase, persistCodingSchemeToDatabase, register, register, setCachingMessageDirectorIF, setCodingSchemeManifest, setCodingSchemeManifestURI, setCodingSchemeReferences, setDoApplyPostLoadManifest, setDoComputeTransitiveClosure, setDoIndexing, setDoRegister, setDoRemoveOnFailure, setInUse, setLoaderPreferences, setLoaderPreferences, setManifestUtil, setOptions, setResourceUri, setStatus, unlock, urnVersionPairToAbsoluteCodingSchemeVersionReference
buildExtensionDescription, getExtensionDescription
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
clearLog, getCodingSchemeManifest, getCodingSchemeManifestURI, getCodingSchemeReferences, getLoaderPreferences, getLog, getOntologyFormat, getOptions, getStatus, load, setCodingSchemeManifest, setCodingSchemeManifestURI, setLoaderPreferences, setLoaderPreferences
getDescription, getName, getProvider, getVersion
protected void launchJob(java.util.Properties connectionProperties, java.lang.String jobConfigFile, java.lang.String jobName) throws java.lang.Exception
connectionProperties
- the connection propertiesjobConfigFile
- the job config filejobName
- the job namejava.lang.Exception
- the exceptionprotected abstract URNVersionPair[] getLoadedCodingSchemes(org.springframework.context.ApplicationContext context)
protected void printStartLogInfo(java.util.Properties connectionProperties, java.lang.String jobConfigFile, java.lang.String jobName)
protected void printJobProperties(java.util.Properties jobProperties)
protected org.springframework.batch.core.JobParameters buildJobParameters(java.util.Properties props)
props
- the propsprotected ProcessState processStateConverter(org.springframework.batch.core.BatchStatus status)
public org.springframework.batch.core.JobExecution getJobExecution()
public static java.net.URI getURIFromPath(java.lang.String path)
public void setLoadedCodingSchemes(URNVersionPair[] loadedCodingSchemes)
public URNVersionPair[] getLoadedCodingSchemes()