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

Field Summary

Fields

Modifier and Type	Field and Description
static String	STEP_ATTRIBUTE_PREFIX

Constructor Summary

Constructors

Constructor and Description
KettleDatabaseRepositoryStepDelegate(KettleDatabaseRepository repository)

Method Summary

Methods

Modifier and Type	Method and Description
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, String copiesString)
StepErrorMeta	loadStepErrorMeta(org.pentaho.di.core.variables.VariableSpace variables, StepMeta stepMeta, List<StepMeta> steps)
StepMeta	loadStepMeta(org.pentaho.di.repository.ObjectId stepId, List<org.pentaho.di.core.database.DatabaseMeta> databases, 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 transformationId)
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

Field Detail

STEP_ATTRIBUTE_PREFIX

public static final String STEP_ATTRIBUTE_PREFIX

See Also:

Constant Field Values

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 stepId,
                    List<org.pentaho.di.core.database.DatabaseMeta> databases,
                    List<PartitionSchema> partitionSchemas)
                      throws org.pentaho.di.core.exception.KettleException

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

Parameters:

rep -

stepId -

databases -

counters -

partitionSchemas -

Throws:

org.pentaho.di.core.exception.KettleException

saveStepMeta

public void saveStepMeta(StepMeta stepMeta,
                org.pentaho.di.repository.ObjectId transformationId)
                  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,
                                            String copiesString)
                                              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