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

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

log, repository

Constructor Summary

Constructors

Constructor and Description
KettleDatabaseRepositoryStepDelegate(KettleDatabaseRepository repository)

Method Summary

Modifier and Type	Method and Description
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)
Map<String,LongObjectId>	getStepTypeCodeToIdMap()
ObjectId	getStepTypeID(String code)
ObjectId[]	getStepTypeIDs(String[] codes, int amount)
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, String copiesString)
StepErrorMeta	loadStepErrorMeta(VariableSpace variables, StepMeta stepMeta, List<StepMeta> steps)
StepMeta	loadStepMeta(ObjectId stepId, List<DatabaseMeta> databases, 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 transformationId)
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

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 ObjectId getStepTypeID(String code)
                       throws KettleException

Throws:

KettleException

getStepTypeIDs

public ObjectId[] getStepTypeIDs(String[] codes,
                                 int amount)
                          throws KettleException

Throws:

KettleException

getStepTypeCodeToIdMap

public Map<String,LongObjectId> getStepTypeCodeToIdMap()
                                                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 stepId,
                             List<DatabaseMeta> databases,
                             List<PartitionSchema> partitionSchemas)
                      throws KettleException

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

Parameters:

rep -

stepId -

databases -

counters -

partitionSchemas -

Throws:

KettleException

saveStepMeta

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