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(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