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
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. |
KettleDatabaseRepositoryStepDelegate
public KettleDatabaseRepositoryStepDelegate(KettleDatabaseRepository repository)
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 transformationid_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