Java Doc for EtlExecutor.java in » Scripting » scriptella » scriptella » execution » Java Source Code / Java DocumentationJava Source Code and Java Documentation

Java Source Code / Java Documentation

1.	6.0 JDK Core
2.	6.0 JDK Modules
3.	6.0 JDK Modules com.sun
4.	6.0 JDK Modules com.sun.java
5.	6.0 JDK Modules sun
6.	6.0 JDK Platform
7.	Ajax
8.	Apache Harmony Java SE
9.	Aspect oriented
10.	Authentication Authorization
11.	Blogger System
12.	Build
13.	Byte Code
14.	Cache
15.	Chart
16.	Chat
17.	Code Analyzer
18.	Collaboration
19.	Content Management System
20.	Database Client
21.	Database DBMS
22.	Database JDBC Connection Pool
23.	Database ORM
24.	Development
25.	EJB Server geronimo
26.	EJB Server GlassFish
27.	EJB Server JBoss 4.2.1
28.	EJB Server resin 3.1.5
29.	ERP CRM Financial
30.	ESB
31.	Forum
32.	GIS
33.	Graphic Library
34.	Groupware
35.	HTML Parser
36.	IDE
37.	IDE Eclipse
38.	IDE Netbeans
39.	Installer
40.	Internationalization Localization
41.	Inversion of Control
42.	Issue Tracking
43.	J2EE
44.	JBoss
45.	JMS
46.	JMX
47.	Library
48.	Mail Clients
49.	Net
50.	Parser
51.	PDF
52.	Portal
53.	Profiler
54.	Project Management
55.	Report
56.	RSS RDF
57.	Rule Engine
58.	Science
59.	Scripting
60.	Search Engine
61.	Security
62.	Sevlet Container
63.	Source Control
64.	Swing Library
65.	Template Engine
66.	Test Coverage
67.	Testing
68.	UML
69.	Web Crawler
70.	Web Framework
71.	Web Mail
72.	Web Server
73.	Web Services
74.	Web Services apache cxf 2.0.1
75.	Web Services AXIS2
76.	Wiki Engine
77.	Workflow Engines
78.	XML
79.	XML UI

Java

Java Tutorial

Illustrator Tutorials

GIMP Tutorials

C# / C Sharp

C# / CSharp Tutorial

C# / CSharp Open Source

SQL Server / T-SQL Tutorial

Oracle PL / SQL

Oracle PL/SQL Tutorial

Flash / Flex / ActionScript

VBA / Excel / Access / Word

XML

XML Tutorial

Microsoft Office PowerPoint 2007 Tutorial

Microsoft Office Excel 2007 Tutorial

Microsoft Office Word 2007 Tutorial

Java Source Code / Java Documentation » Scripting » scriptella » scriptella.execution

Source Cross Reference Class Diagram Java Document (Java Doc)

java.lang .Object

scriptella.execution .EtlExecutor

All known Subclasses:   scriptella.execution .TestableEtlExecutor,  scriptella.driver.spring .EtlExecutorBean,
EtlExecutor
public class EtlExecutor implements Runnable,Callable<ExecutionStatistics>(Code)
Executor for ETL files.
Use ConfigurationFactory to parse script files and to configure the executor.
The usage scenario of this class may be described using the following steps:

EtlExecutor.EtlExecutor(scriptella.configuration.ConfigurationEl) Create an instance of this class and pass a scriptella.configuration.ConfigurationFactory.createConfiguration script file configuration .
EtlExecutor.execute() Execute the script

Additionally simplified helper methods are declared in this class:

EtlExecutor.newExecutor(java.io.File)
EtlExecutor.newExecutor(java.net.URL)
EtlExecutor.newExecutor(java.net.URL,java.util.Map)

ETL Cancellation
Scriptella execution model relies on a standard Java Thread.interrupt mechanism.
To interrupt the ETL execution invoke Thread.interrupt on a thread which EtlExecutor.execute() started ETL operation. As a part of interruption process the engine tries to roll back all changes made during the ETL operation.
java.util.concurrent.ExecutorService and java.util.concurrent.Future can also be used to control ETL execution.
Integration with third-party systems
For convenience EtlExecutor implements Runnable and java.util.concurrent.Callable . This feature simplifies integration of Scriptella executors with java.util.concurrent.Executors or other systems like Spring/Quartz etc. It also minimizes application code dependency on Scriptella.
author:
   Fyodor Kupolov
version:
   1.0

Constructor Summary
public EtlExecutor()
     Creates ETL executor.
public EtlExecutor(ConfigurationEl configuration)
     Creates an ETL executor for specified configuration file.

Method Summary
public ExecutionStatistics call()
     A synonym for EtlExecutor.execute() .
void closeAll(EtlContext ctx)

void commitAll(EtlContext ctx)

public ExecutionStatistics execute()
     Executes ETL based on a specified configuration.
public ExecutionStatistics execute(ProgressIndicator indicator)
     Executes ETL based on a specified configuration.
Parameters:
  indicator - progress indicator to use.
public ConfigurationEl getConfiguration()
     Returns ETL configuration for this executor.
public boolean isJmxEnabled()
     Returns true if monitoring/management via JMX is enabled.
public static EtlExecutor newExecutor(File scriptFile)
     Converts file to URL and invokes EtlExecutor.newExecutor(java.net.URL) .
Parameters:
  scriptFile - ETL file.
public static EtlExecutor newExecutor(URL scriptFileUrl)
     Helper method to create a new ScriptExecutor for specified script URL.
Calls EtlExecutor.newExecutor(java.net.URL,java.util.Map) and passes System.getProperties System properties as external properties.
Parameters:
  scriptFileUrl - URL of script file.
public static EtlExecutor newExecutor(URL scriptFileUrl, Map<String, ?> externalProperties)
     Helper method to create a new ScriptExecutor for specified script URL.
protected EtlContext prepare(ProgressIndicator indicator)
     Prepares the scripts context.
Parameters:
  indicator - progress indicator to use.
void rollbackAll(EtlContext ctx)

public void run()
     A runnable adapter for EtlExecutor.execute() method.
public void setConfiguration(ConfigurationEl configuration)
     Sets ETL configuration.
public void setJmxEnabled(boolean jmxEnabled)
     Enables or disables ETL monitoring/management via JMX.

Constructor Detail
EtlExecutor
public EtlExecutor()(Code)
Creates ETL executor.

EtlExecutor
public EtlExecutor(ConfigurationEl configuration)(Code)
Creates an ETL executor for specified configuration file.
Parameters:
  configuration - ETL configuration.

Method Detail
call
public ExecutionStatistics call() throws EtlExecutorException(Code)
A synonym for EtlExecutor.execute() .

closeAll
void closeAll(EtlContext ctx)(Code)

commitAll
void commitAll(EtlContext ctx)(Code)

execute
public ExecutionStatistics execute() throws EtlExecutorException(Code)
Executes ETL based on a specified configuration. execution statistics for ETL execution.
throws:
  EtlExecutorException - if ETL fails.
See Also:   EtlExecutor.execute(scriptella.interactive.ProgressIndicator)

execute
public ExecutionStatistics execute(ProgressIndicator indicator) throws EtlExecutorException(Code)
Executes ETL based on a specified configuration.
Parameters:
  indicator - progress indicator to use. execution statistics for ETL execution.
throws:
  EtlExecutorException - if ETL fails.

getConfiguration
public ConfigurationEl getConfiguration()(Code)
Returns ETL configuration for this executor. ETL configuration.

isJmxEnabled
public boolean isJmxEnabled()(Code)
Returns true if monitoring/management via JMX is enabled.
If jmxEnabled=true the executor registers MBeans for executed ETL files. The object names of the mbeans have the following form: scriptella: type=etl,url="ETL_FILE_URL" true if monitoring/management via JMX is enabled.

newExecutor
public static EtlExecutor newExecutor(File scriptFile)(Code)
Converts file to URL and invokes EtlExecutor.newExecutor(java.net.URL) .
Parameters:
  scriptFile - ETL file. configured instance of script executor.
See Also:   EtlExecutor.newExecutor(java.net.URL)

newExecutor
public static EtlExecutor newExecutor(URL scriptFileUrl)(Code)
Helper method to create a new ScriptExecutor for specified script URL.
Calls EtlExecutor.newExecutor(java.net.URL,java.util.Map) and passes System.getProperties System properties as external properties.
Parameters:
  scriptFileUrl - URL of script file. configured instance of script executor.

newExecutor
public static EtlExecutor newExecutor(URL scriptFileUrl, Map<String, ?> externalProperties)(Code)
Helper method to create a new ScriptExecutor for specified script URL.
Parameters:
  scriptFileUrl - URL of script file.
Parameters:
  externalProperties - see ConfigurationFactory.setExternalParameters(java.util.Map) configured instance of script executor.
See Also:   ConfigurationFactory

prepare
protected EtlContext prepare(ProgressIndicator indicator)(Code)
Prepares the scripts context.
Parameters:
  indicator - progress indicator to use. prepared scripts context.

rollbackAll
void rollbackAll(EtlContext ctx)(Code)

run
public void run() throws SystemException(Code)
A runnable adapter for EtlExecutor.execute() method.
Please note that due to a checked exceptions limitation a scriptella.core.SystemException is thrown instead of the scriptella.execution.EtlExecutorException .
throws:
  SystemException - a wrapped scriptella.execution.EtlExecutorException.
See Also:   EtlExecutor.execute()

setConfiguration
public void setConfiguration(ConfigurationEl configuration)(Code)
Sets ETL configuration.
Parameters:
  configuration - ETL configuration.

setJmxEnabled
public void setJmxEnabled(boolean jmxEnabled)(Code)
Enables or disables ETL monitoring/management via JMX.
If jmxEnabled=true the executor registers MBeans for executed ETL files. The object names of the mbeans have the following form: scriptella: type=etl,url="ETL_FILE_URL"
Parameters:
  jmxEnabled - true if monitoring/management via JMX is enabled.
See Also:   scriptella.execution.JmxEtlManagerMBean

Methods inherited from java.lang.Object
native protected Object clone() throws CloneNotSupportedException(Code)(Java Doc)
public boolean equals(Object obj)(Code)(Java Doc)
protected void finalize() throws Throwable(Code)(Java Doc)
final native public Class getClass()(Code)(Java Doc)
native public int hashCode()(Code)(Java Doc)
final native public void notify()(Code)(Java Doc)
final native public void notifyAll()(Code)(Java Doc)
public String toString()(Code)(Java Doc)
final native public void wait(long timeout) throws InterruptedException(Code)(Java Doc)
final public void wait(long timeout, int nanos) throws InterruptedException(Code)(Java Doc)
final public void wait() throws InterruptedException(Code)(Java Doc)

www.java2java.com | Contact Us

All other trademarks are property of their respective owners.