org.pentaho.di.repository.kdr.delegates
Class KettleDatabaseRepositoryStepDelegate

java.lang.Object
  org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate
      org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryStepDelegate

public class KettleDatabaseRepositoryStepDelegate
extends KettleDatabaseRepositoryBaseDelegate

Constructor Summary

KettleDatabaseRepositoryStepDelegate(KettleDatabaseRepository repository)

Method Summary

int	getNrStepAttributes(org.pentaho.di.repository.ObjectId id_step)
int	getNrSteps(org.pentaho.di.repository.ObjectId id_transformation)
org.pentaho.di.core.RowMetaAndData	getStep(org.pentaho.di.repository.ObjectId id_step)
org.pentaho.di.core.RowMetaAndData	getStepAttribute(org.pentaho.di.repository.ObjectId id_step_attribute)
org.pentaho.di.repository.ObjectId	getStepID(String name, org.pentaho.di.repository.ObjectId id_transformation)
org.pentaho.di.core.RowMetaAndData	getStepType(org.pentaho.di.repository.ObjectId id_step_type)
String	getStepTypeCode(org.pentaho.di.repository.ObjectId id_database_type)
org.pentaho.di.repository.ObjectId	getStepTypeID(String code)
org.pentaho.di.repository.ObjectId	insertStep(org.pentaho.di.repository.ObjectId id_transformation, String name, String description, String steptype, boolean distribute, long copies, long gui_location_x, long gui_location_y, boolean gui_draw)
StepErrorMeta	loadStepErrorMeta(org.pentaho.di.core.variables.VariableSpace variables, StepMeta stepMeta, List<StepMeta> steps)
StepMeta	loadStepMeta(org.pentaho.di.repository.ObjectId id_step, List<org.pentaho.di.core.database.DatabaseMeta> databases, Map<String,org.pentaho.di.core.Counter> counters, List<PartitionSchema> partitionSchemas) Create a new step by loading the metadata from the specified repository.
StepPartitioningMeta	loadStepPartitioningMeta(org.pentaho.di.repository.ObjectId id_step)
void	saveStepErrorMeta(StepErrorMeta meta, org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step)
void	saveStepMeta(StepMeta stepMeta, org.pentaho.di.repository.ObjectId id_transformation)
void	saveStepPartitioningMeta(StepPartitioningMeta meta, org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step) Saves partitioning properties in the repository for the given step.

Methods inherited from class org.pentaho.di.repository.kdr.delegates.KettleDatabaseRepositoryBaseDelegate

quote, quoteTable

Methods inherited from class java.lang.Object

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

Constructor Detail

KettleDatabaseRepositoryStepDelegate

public KettleDatabaseRepositoryStepDelegate(KettleDatabaseRepository repository)

Method Detail

getStepTypeID

public org.pentaho.di.repository.ObjectId getStepTypeID(String code)
                                                 throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getStepID

public org.pentaho.di.repository.ObjectId getStepID(String name,
                                                    org.pentaho.di.repository.ObjectId id_transformation)
                                             throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getStepTypeCode

public String getStepTypeCode(org.pentaho.di.repository.ObjectId id_database_type)
                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getStep

public org.pentaho.di.core.RowMetaAndData getStep(org.pentaho.di.repository.ObjectId id_step)
                                           throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getStepType

public org.pentaho.di.core.RowMetaAndData getStepType(org.pentaho.di.repository.ObjectId id_step_type)
                                               throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getStepAttribute

public org.pentaho.di.core.RowMetaAndData getStepAttribute(org.pentaho.di.repository.ObjectId id_step_attribute)
                                                    throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadStepMeta

public StepMeta loadStepMeta(org.pentaho.di.repository.ObjectId id_step,
                             List<org.pentaho.di.core.database.DatabaseMeta> databases,
                             Map<String,org.pentaho.di.core.Counter> counters,
                             List<PartitionSchema> partitionSchemas)
                      throws org.pentaho.di.core.exception.KettleException

Create a new step by loading the metadata from the specified repository.

Parameters:

rep -

id_step -

databases -

counters -

partitionSchemas -

Throws:

org.pentaho.di.core.exception.KettleException

saveStepMeta

public void saveStepMeta(StepMeta stepMeta,
                         org.pentaho.di.repository.ObjectId id_transformation)
                  throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveStepErrorMeta

public void saveStepErrorMeta(StepErrorMeta meta,
                              org.pentaho.di.repository.ObjectId id_transformation,
                              org.pentaho.di.repository.ObjectId id_step)
                       throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadStepErrorMeta

public StepErrorMeta loadStepErrorMeta(org.pentaho.di.core.variables.VariableSpace variables,
                                       StepMeta stepMeta,
                                       List<StepMeta> steps)
                                throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

loadStepPartitioningMeta

public StepPartitioningMeta loadStepPartitioningMeta(org.pentaho.di.repository.ObjectId id_step)
                                              throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

saveStepPartitioningMeta

public void saveStepPartitioningMeta(StepPartitioningMeta meta,
                                     org.pentaho.di.repository.ObjectId id_transformation,
                                     org.pentaho.di.repository.ObjectId id_step)
                              throws org.pentaho.di.core.exception.KettleException

Saves partitioning properties in the repository for the given step.

Parameters:

meta - the partitioning metadata to store.

id_transformation - the ID of the transformation

id_step - the ID of the step

Throws:

org.pentaho.di.core.exception.KettleDatabaseException - In case anything goes wrong

org.pentaho.di.core.exception.KettleException

insertStep

public org.pentaho.di.repository.ObjectId insertStep(org.pentaho.di.repository.ObjectId id_transformation,
                                                     String name,
                                                     String description,
                                                     String steptype,
                                                     boolean distribute,
                                                     long copies,
                                                     long gui_location_x,
                                                     long gui_location_y,
                                                     boolean gui_draw)
                                              throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getNrSteps

public int getNrSteps(org.pentaho.di.repository.ObjectId id_transformation)
               throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getNrStepAttributes

public int getNrStepAttributes(org.pentaho.di.repository.ObjectId id_step)
                        throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException