|
Oracle Fusion Middleware External Executors Java API Reference for Oracle Business Intelligence Data Warehouse Administration Console 11g Release 1 (11.1.1) E20491-01 |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface DACExecutor
DACExecutor is an interface to an ETL execution engine. Executor is instantiated during ETL and is used to communicate with one ETL engine. Multiple instances of DACExecutors could be created during ETL to communicate with multiple ETL Engines of a specific type. DACExecutor is initialized with a set of properties (as defined in DAC Metadata) and is used to create DACExecutorJobs, one per DAC task. To that end a map of DAC parameters relevant for the task and DAC Task information are provided. Task information includes task name, command name (workflow name in case of Informatica), source and target table information.
Method Summary | |
---|---|
void |
cleanUp() Cleans up executor instance once execution is over. |
DACExecutorJob |
createJob(DACTaskDefinition taskDefinition, java.util.Map<java.lang.String,java.lang.String> runtimeParameters, java.util.Map<java.lang.String,java.lang.String> contextMap) Creates and initializes an instance of DACExecutorJob. |
int |
getParallelismLevel() Returns executor parallelism level. |
void |
init(java.util.Map<java.lang.Object,java.lang.Object> properties) Initializes executor with the properties specified in DAC repository. |
boolean |
isValid() Verifies if an executor is valid. |
void |
prepareForExecution() Prepares for execution. |
void |
test() Tests ETL engine availability. |
Method Detail |
---|
void init(java.util.Map<java.lang.Object,java.lang.Object> properties) throws DACExecutorInitializationException
properties
- executor propertiesDACExecutorInitializationException
- if executor can't be initializedboolean isValid() throws DACExecutorInvalidPropertiesException
DACExecutorInvalidPropertiesException
- if there is an error while verifying validityvoid test() throws DACExecutorConnectionException
DACExecutorConnectionException
- if connection to ETL engine can't be establishedvoid prepareForExecution() throws DACExecutorConnectionException
DACExecutorConnectionException
- if connection to ETL engine can't be establishedDACExecutorJob createJob(DACTaskDefinition taskDefinition, java.util.Map<java.lang.String,java.lang.String> runtimeParameters, java.util.Map<java.lang.String,java.lang.String> contextMap) throws DACExecutorJobInitializationException
taskDefinition
- DAC task definition with source&target table information, command name, etc.runtimeParameters
- DAC runtime parameters (currency, language, etc.)contextMap
- map of context names and values applicable to a given task (see getExecutionContextNames() in DACExecutorDescriptor for more detail)DACExecutorJobInitializationException
- if a job can't be initializedint getParallelismLevel()
void cleanUp()
|
Oracle Fusion Middleware External Executors Java API Reference for Oracle Business Intelligence Data Warehouse Administration Console 11g Release 1 (11.1.1) E20491-01 |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |