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

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

public class KettleDatabaseRepositoryStepDelegate
extends KettleDatabaseRepositoryBaseDelegate


Constructor Summary
KettleDatabaseRepositoryStepDelegate(KettleDatabaseRepository repository)
           
 
Method Summary
 int getNrStepAttributes(ObjectId id_step)
           
 int getNrSteps(ObjectId id_transformation)
           
 RowMetaAndData getStep(ObjectId id_step)
           
 RowMetaAndData getStepAttribute(ObjectId id_step_attribute)
           
 ObjectId getStepID(String name, ObjectId id_transformation)
           
 RowMetaAndData getStepType(ObjectId id_step_type)
           
 String getStepTypeCode(ObjectId id_database_type)
           
 ObjectId getStepTypeID(String code)
           
 ObjectId insertStep(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(VariableSpace variables, StepMeta stepMeta, List<StepMeta> steps)
           
 StepMeta loadStepMeta(ObjectId id_step, List<DatabaseMeta> databases, Map<String,Counter> counters, List<PartitionSchema> partitionSchemas)
          Create a new step by loading the metadata from the specified repository.
 StepPartitioningMeta loadStepPartitioningMeta(ObjectId id_step)
           
 void saveStepErrorMeta(StepErrorMeta meta, ObjectId id_transformation, ObjectId id_step)
           
 void saveStepMeta(StepMeta stepMeta, ObjectId id_transformation)
           
 void saveStepPartitioningMeta(StepPartitioningMeta meta, ObjectId id_transformation, 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 ObjectId getStepTypeID(String code)
                       throws KettleException
Throws:
KettleException

getStepID

public ObjectId getStepID(String name,
                          ObjectId id_transformation)
                   throws KettleException
Throws:
KettleException

getStepTypeCode

public String getStepTypeCode(ObjectId id_database_type)
                       throws KettleException
Throws:
KettleException

getStep

public RowMetaAndData getStep(ObjectId id_step)
                       throws KettleException
Throws:
KettleException

getStepType

public RowMetaAndData getStepType(ObjectId id_step_type)
                           throws KettleException
Throws:
KettleException

getStepAttribute

public RowMetaAndData getStepAttribute(ObjectId id_step_attribute)
                                throws KettleException
Throws:
KettleException

loadStepMeta

public StepMeta loadStepMeta(ObjectId id_step,
                             List<DatabaseMeta> databases,
                             Map<String,Counter> counters,
                             List<PartitionSchema> partitionSchemas)
                      throws KettleException
Create a new step by loading the metadata from the specified repository.

Parameters:
rep -
id_step -
databases -
counters -
partitionSchemas -
Throws:
KettleException

saveStepMeta

public void saveStepMeta(StepMeta stepMeta,
                         ObjectId id_transformation)
                  throws KettleException
Throws:
KettleException

saveStepErrorMeta

public void saveStepErrorMeta(StepErrorMeta meta,
                              ObjectId id_transformation,
                              ObjectId id_step)
                       throws KettleException
Throws:
KettleException

loadStepErrorMeta

public StepErrorMeta loadStepErrorMeta(VariableSpace variables,
                                       StepMeta stepMeta,
                                       List<StepMeta> steps)
                                throws KettleException
Throws:
KettleException

loadStepPartitioningMeta

public StepPartitioningMeta loadStepPartitioningMeta(ObjectId id_step)
                                              throws KettleException
Throws:
KettleException

saveStepPartitioningMeta

public void saveStepPartitioningMeta(StepPartitioningMeta meta,
                                     ObjectId id_transformation,
                                     ObjectId id_step)
                              throws 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:
KettleDatabaseException - In case anything goes wrong
KettleException

insertStep

public ObjectId insertStep(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 KettleException
Throws:
KettleException

getNrSteps

public int getNrSteps(ObjectId id_transformation)
               throws KettleException
Throws:
KettleException

getNrStepAttributes

public int getNrStepAttributes(ObjectId id_step)
                        throws KettleException
Throws:
KettleException