ca.sqlpower.architect.etl.kettle
Class KettleJob

java.lang.Object
  ca.sqlpower.architect.etl.kettle.KettleJob

All Implemented Interfaces:

ca.sqlpower.util.Monitorable

public class KettleJob
extends java.lang.Object
implements ca.sqlpower.util.Monitorable

This class stores the settings for creating Kettle jobs. This class also creates Kettle jobs based on a given session's play pen. The jobs and transformations created by this class can be stored in either a file or repository.

Constructor Summary

KettleJob(ArchitectSession session)

KettleJob(ArchitectSession session, KettleRepositoryDirectoryChooser chooser)

Method Summary

void	doExport(java.util.List<SQLTable> tableList, SQLDatabase targetDB) This method translates the list of SQLTables to a Kettle Job and Transformations and saves them to KJB and KTR files OR a repository.
java.lang.String	getFilePath()
java.lang.String	getJobName()
java.lang.Integer	getJobSize()
int	getKettleJoinType()
java.lang.String	getMessage()
int	getProgress()
ca.sqlpower.sql.SPDataSource	getRepository()
java.lang.String	getSchemaName()
java.util.List<java.lang.String>	getTasksToDo()
boolean	hasStarted()
boolean	isCancelled()
boolean	isFinished()
boolean	isSavingToFile()
void	setCancelled(boolean cancelled)
void	setFilePath(java.lang.String filePath)
void	setJobName(java.lang.String jobName)
void	setKettleJoinType(int kettleJoinType)
void	setRepository(ca.sqlpower.sql.SPDataSource source)
void	setRepositoryDirectoryChooser(KettleRepositoryDirectoryChooser chooser)
void	setSavingToFile(boolean savingToFile)
void	setSchemaName(java.lang.String schemaName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KettleJob

public KettleJob(ArchitectSession session,
                 KettleRepositoryDirectoryChooser chooser)

KettleJob

public KettleJob(ArchitectSession session)

Method Detail

doExport

public void doExport(java.util.List<SQLTable> tableList,
                     SQLDatabase targetDB)
              throws ArchitectException,
                     java.lang.RuntimeException,
                     java.io.IOException,
                     org.pentaho.di.core.exception.KettleException,
                     java.sql.SQLException

This method translates the list of SQLTables to a Kettle Job and Transformations and saves them to KJB and KTR files OR a repository.

Throws:

org.pentaho.di.core.exception.KettleException

ArchitectException

java.lang.RuntimeException

java.io.IOException

java.sql.SQLException

getFilePath

public java.lang.String getFilePath()

setFilePath

public void setFilePath(java.lang.String filePath)

getJobName

public java.lang.String getJobName()

setJobName

public void setJobName(java.lang.String jobName)

getKettleJoinType

public int getKettleJoinType()

setKettleJoinType

public void setKettleJoinType(int kettleJoinType)

getSchemaName

public java.lang.String getSchemaName()

setSchemaName

public void setSchemaName(java.lang.String schemaName)

getTasksToDo

public java.util.List<java.lang.String> getTasksToDo()

getJobSize

public java.lang.Integer getJobSize()

Specified by:

getJobSize in interface ca.sqlpower.util.Monitorable

getMessage

public java.lang.String getMessage()

Specified by:

getMessage in interface ca.sqlpower.util.Monitorable

getProgress

public int getProgress()

Specified by:

getProgress in interface ca.sqlpower.util.Monitorable

hasStarted

public boolean hasStarted()

Specified by:

hasStarted in interface ca.sqlpower.util.Monitorable

isFinished

public boolean isFinished()

Specified by:

isFinished in interface ca.sqlpower.util.Monitorable

setCancelled

public void setCancelled(boolean cancelled)

Specified by:

setCancelled in interface ca.sqlpower.util.Monitorable

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface ca.sqlpower.util.Monitorable

isSavingToFile

public boolean isSavingToFile()

setSavingToFile

public void setSavingToFile(boolean savingToFile)

setRepository

public void setRepository(ca.sqlpower.sql.SPDataSource source)

setRepositoryDirectoryChooser

public void setRepositoryDirectoryChooser(KettleRepositoryDirectoryChooser chooser)

getRepository

public ca.sqlpower.sql.SPDataSource getRepository()