Package 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	Description
static String	STEP_ATTRIBUTE_PREFIX

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

log, repository

Constructor Summary

Constructors

Constructor	Description
KettleDatabaseRepositoryStepDelegate(KettleDatabaseRepository repository)

Method Summary

Modifier and Type	Method	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)
Map<String,org.pentaho.di.repository.LongObjectId>	getStepTypeCodeToIdMap()
org.pentaho.di.repository.ObjectId	getStepTypeID(String code)
org.pentaho.di.repository.ObjectId[]	getStepTypeIDs(String[] codes, int amount)
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

clone, equals, finalize, 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

getStepTypeIDs

public org.pentaho.di.repository.ObjectId[] getStepTypeIDs(String[] codes,
                                                           int amount)
                                                    throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

getStepTypeCodeToIdMap

public Map<String,org.pentaho.di.repository.LongObjectId> getStepTypeCodeToIdMap()
                                                                                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