public class TransMeta extends AbstractMeta implements org.pentaho.di.core.xml.XMLInterface, Comparator<TransMeta>, Comparable<TransMeta>, Cloneable, ResourceExportInterface, org.pentaho.di.repository.RepositoryElementInterface, org.pentaho.di.core.logging.LoggingObjectInterface
Modifier and Type | Class and Description |
---|---|
static class |
TransMeta.TransformationType
The TransformationType enum describes the various types of transformations in terms of execution, including Normal,
Serial Single-Threaded, and Single-Threaded.
|
Modifier and Type | Field and Description |
---|---|
static int |
BORDER_INDENT |
static String[] |
desc_type_undo
A list of localized strings corresponding to string descriptions of the undo/redo actions.
|
static org.pentaho.di.repository.RepositoryObjectType |
REPOSITORY_ELEMENT_TYPE
A constant specifying the repository element type as a Transformation.
|
static String |
STRING_TRANSMETA
A constant used by the logging operations to indicate any logged messages are related to transformation meta-data.
|
static String |
XML_TAG
A constant specifying the tag value for the XML node of the transformation.
|
static String |
XML_TAG_CLUSTERSCHEMAS
A constant specifying the tag value for the XML node of the cluster schemas.
|
static String |
XML_TAG_NOTEPADS
A constant specifying the tag value for the XML node of the notes.
|
static String |
XML_TAG_ORDER
A constant specifying the tag value for the XML node of the order of steps.
|
static String |
XML_TAG_PARAMETERS
A constant specifying the tag value for the XML node of the transformation parameters.
|
static String |
XML_TAG_PARTITIONSCHEMAS
A constant specifying the tag value for the XML node of the transformation's partition schemas.
|
static String |
XML_TAG_SLAVESERVERS
A constant specifying the tag value for the XML node of the slave servers.
|
static String |
XML_TAG_STEP_ERROR_HANDLING
A constant specifying the tag value for the XML node of the steps' error-handling information.
|
TYPE_UNDO_CHANGE, TYPE_UNDO_DELETE, TYPE_UNDO_NEW, TYPE_UNDO_POSITION
Constructor and Description |
---|
TransMeta()
Builds a new empty transformation.
|
TransMeta(InputStream xmlStream,
Repository rep,
boolean setInternalVariables,
org.pentaho.di.core.variables.VariableSpace parentVariableSpace,
org.pentaho.di.core.gui.OverwritePrompter prompter)
Instantiates a new transformation meta-data object.
|
TransMeta(Node transnode,
Repository rep)
Parse a file containing the XML that describes the transformation.
|
TransMeta(String fname)
Parses a file containing the XML that describes the transformation.
|
TransMeta(String fname,
boolean setInternalVariables)
Parses a file containing the XML that describes the transformation.
|
TransMeta(String fname,
org.pentaho.metastore.api.IMetaStore metaStore,
Repository rep,
boolean setInternalVariables,
org.pentaho.di.core.variables.VariableSpace parentVariableSpace,
org.pentaho.di.core.gui.OverwritePrompter prompter)
Parses a file containing the XML that describes the transformation.
|
TransMeta(String fname,
Repository rep)
Parses a file containing the XML that describes the transformation.
|
TransMeta(String fname,
Repository rep,
boolean setInternalVariables)
Parses a file containing the XML that describes the transformation.
|
TransMeta(String fname,
Repository rep,
boolean setInternalVariables,
org.pentaho.di.core.variables.VariableSpace parentVariableSpace)
Parses a file containing the XML that describes the transformation.
|
TransMeta(String fname,
Repository rep,
boolean setInternalVariables,
org.pentaho.di.core.variables.VariableSpace parentVariableSpace,
org.pentaho.di.core.gui.OverwritePrompter prompter)
Parses a file containing the XML that describes the transformation.
|
TransMeta(String filename,
String name) |
TransMeta(String filename,
String name,
String[] arguments)
Deprecated.
passing in arguments (a runtime argument) into the metadata is deprecated, pass it to Trans
|
TransMeta(String fname,
org.pentaho.di.core.variables.VariableSpace parentVariableSpace)
Parses a file containing the XML that describes the transformation.
|
TransMeta(org.pentaho.di.core.variables.VariableSpace parent)
Builds a new empty transformation with a set of variables to inherit from.
|
Modifier and Type | Method and Description |
---|---|
void |
addDependency(int p,
TransDependency td)
Add a new dependency to the transformation on a certain location (i.e.
|
void |
addDependency(TransDependency td)
Add a new dependency to the transformation.
|
void |
addMissingTrans(MissingTrans trans) |
void |
addOrReplaceClusterSchema(ClusterSchema clusterSchema)
Add a new cluster schema to the transformation if that didn't exist yet.
|
void |
addOrReplacePartitionSchema(PartitionSchema partitionSchema)
Add a new partition schema to the transformation if that didn't exist yet.
|
void |
addOrReplaceStep(StepMeta stepMeta)
Add a new step to the transformation if that step didn't exist yet.
|
void |
addStep(int p,
StepMeta stepMeta)
Add a new step to the transformation at the specified index.
|
void |
addStep(StepMeta stepMeta)
Add a new step to the transformation.
|
void |
addStepChangeListener(int p,
StepMetaChangeListenerInterface list) |
void |
addStepChangeListener(StepMetaChangeListenerInterface listener) |
void |
addTransHop(int p,
TransHopMeta hi)
Add a new hop to the transformation on a certain location (i.e.
|
void |
addTransHop(TransHopMeta hi)
Add a new hop to the transformation.
|
void |
analyseImpact(List<DatabaseImpact> impact,
org.pentaho.di.core.ProgressMonitorListener monitor)
Determines the impact of the different steps in a transformation on databases, tables and field.
|
void |
cancelQueries()
Cancels queries opened for checking & fieldprediction.
|
void |
checkRowMixingStatically(StepMeta stepMeta,
org.pentaho.di.core.ProgressMonitorListener monitor)
Check a step to see if there are no multiple steps to read from.
|
void |
checkSteps(List<org.pentaho.di.core.CheckResultInterface> remarks,
boolean only_selected,
org.pentaho.di.core.ProgressMonitorListener monitor)
Deprecated.
|
void |
checkSteps(List<org.pentaho.di.core.CheckResultInterface> remarks,
boolean only_selected,
org.pentaho.di.core.ProgressMonitorListener monitor,
org.pentaho.di.core.variables.VariableSpace space,
Repository repository,
org.pentaho.metastore.api.IMetaStore metaStore)
Checks all the steps and fills a List of (CheckResult) remarks.
|
void |
clear()
Clears the transformation's meta-data, including the lists of databases, steps, hops, notes, dependencies,
partition schemas, slave servers, and cluster schemas.
|
void |
clearCaches()
Clears the step fields and loop caches.
|
void |
clearChanged()
Clears the different changed flags of the transformation.
|
Object |
clone()
Clones the transformation meta-data object.
|
int |
compare(TransMeta t1,
TransMeta t2)
Compares two transformation on name, filename, repository directory, etc.
|
int |
compareTo(TransMeta o)
Compares this transformation's meta-data to the specified transformation's meta-data.
|
boolean |
containsStepMeta(StepMeta stepMeta) |
boolean |
equals(Object obj)
Checks whether this transformation's meta-data object is equal to the specified object.
|
String |
exportResources(org.pentaho.di.core.variables.VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository,
org.pentaho.metastore.api.IMetaStore metaStore)
Exports the specified objects to a flat-file system, adding content with filename keys to a set of definitions.
|
ClusterSchema |
findClusterSchema(String name)
Find a clustering schema using its name.
|
ClusterSchema |
findFirstUsedClusterSchema()
Finds the first used cluster schema.
|
StepMeta |
findMappingInputStep(String stepname)
Finds the mapping input step with the specified name.
|
StepMeta |
findMappingOutputStep(String stepname)
Finds the mapping output step with the specified name.
|
StepMeta |
findNextStep(StepMeta stepMeta,
int nr)
Deprecated.
just get the next steps as an array
|
List<StepMeta> |
findNextSteps(StepMeta stepMeta)
Retrieve a list of succeeding steps for a certain originating step.
|
int |
findNrInfoSteps(StepMeta stepMeta)
Find the the number of informational steps for a certain step.
|
int |
findNrNextSteps(StepMeta stepMeta)
Deprecated.
just get the next steps as an array
|
int |
findNrPrevSteps(StepMeta stepMeta)
Find the number of steps that precede the indicated step.
|
int |
findNrPrevSteps(StepMeta stepMeta,
boolean info)
Deprecated.
please use method findPreviousSteps
|
int |
findNrPrevSteps(String stepname)
Deprecated.
|
int |
findNrPrevSteps(String stepname,
boolean info)
Deprecated.
|
PartitionSchema |
findPartitionSchema(String name)
Find a partition schema using its name.
|
boolean |
findPrevious(StepMeta startStep,
StepMeta stepToFind)
Looks in the transformation to find a step in a previous location starting somewhere.
|
List<StepMeta> |
findPreviousSteps(StepMeta stepMeta)
Get the list of previous steps for a certain reference step.
|
List<StepMeta> |
findPreviousSteps(StepMeta stepMeta,
boolean info)
Get the previous steps on a certain location taking into account the steps being informational or not.
|
StepMeta |
findPrevStep(StepMeta stepMeta,
int nr)
Find the previous step on a certain location (i.e.
|
StepMeta |
findPrevStep(StepMeta stepMeta,
int nr,
boolean info)
Deprecated.
please use method findPreviousSteps
|
StepMeta |
findPrevStep(String stepname,
int nr)
Deprecated.
|
StepMeta |
findPrevStep(String stepname,
int nr,
boolean info)
Deprecated.
|
StepMeta |
findStep(String name)
Searches the list of steps for a step with a certain name.
|
StepMeta |
findStep(String name,
StepMeta exclude)
Searches the list of steps for a step with a certain name while excluding one step.
|
TransHopMeta |
findTransHop(StepMeta from,
StepMeta to)
Search all hops for a hop where a certain step is at the start and another is at the end.
|
TransHopMeta |
findTransHop(StepMeta from,
StepMeta to,
boolean disabledToo)
Search all hops for a hop where a certain step is at the start and another is at the end.
|
TransHopMeta |
findTransHop(String name)
Searches the list of hops for a hop with a certain name.
|
TransHopMeta |
findTransHop(TransHopMeta hi)
Find a certain hop in the transformation.
|
TransHopMeta |
findTransHopFrom(StepMeta fromstep)
Search all hops for a hop where a certain step is at the start.
|
TransHopMeta |
findTransHopTo(StepMeta tostep)
Search all hops for a hop where a certain step is at the end.
|
String |
getAlternativeStepname(String stepname)
Proposes an alternative stepname when the original already exists.
|
String[] |
getArguments()
Deprecated.
moved to Trans
|
String[] |
getClusterSchemaNames()
Gets the cluster schema names.
|
List<ClusterSchema> |
getClusterSchemas()
Gets a list of the cluster schemas used by the transformation.
|
Hashtable<String,org.pentaho.di.core.Counter> |
getCounters()
Deprecated.
moved to Trans
|
org.pentaho.di.core.DBCache |
getDbCache()
Gets the database cache object.
|
String |
getDefaultExtension()
Gets the default extension for a transformation.
|
List<TransDependency> |
getDependencies()
Gets a list of dependencies for the transformation
|
TransDependency |
getDependency(int i)
Retrieves a dependency on a certain location (i.e.
|
int |
getFeedbackSize()
Gets the feedback size.
|
String |
getFileType()
Gets the file type.
|
String[] |
getFilterExtensions()
Gets the transformation filter extensions.
|
String[] |
getFilterNames()
Gets the transformation filter names.
|
StepMeta[] |
getInfoStep(StepMeta stepMeta)
Get the informational steps for a certain step.
|
byte[] |
getKey() |
org.pentaho.di.core.logging.LogChannelInterface |
getLogChannel()
Gets the log channel.
|
String |
getLogChannelId()
Gets the log channel ID.
|
List<LogTableInterface> |
getLogTables()
Gets a list of the log tables (transformation, step, performance, channel) for the transformation.
|
org.pentaho.di.core.database.DatabaseMeta |
getMaxDateConnection()
Gets the database connection associated with "max date" processing.
|
double |
getMaxDateDifference()
Gets the maximum date difference between start and end dates for row/record processing.
|
String |
getMaxDateField()
Gets the date field associated with "max date" processing.
|
double |
getMaxDateOffset()
Gets the amount by which to increase the "max date" difference.
|
String |
getMaxDateTable()
Gets the database table providing a date to be used in "max date" processing.
|
org.pentaho.di.core.gui.Point |
getMaximum()
Gets the maximum size of the canvas by calculating the maximum location of a step.
|
MetricsLogTable |
getMetricsLogTable() |
org.pentaho.di.core.gui.Point |
getMinimum()
Gets the minimum point on the canvas of a transformation.
|
List<MissingTrans> |
getMissingTrans() |
String[] |
getNextStepNames(StepMeta stepMeta)
Retrieve an array of succeeding step names for a certain originating step.
|
StepMeta[] |
getNextSteps(StepMeta stepMeta)
Deprecated.
use findNextSteps instead
|
org.pentaho.di.core.logging.LoggingObjectType |
getObjectType()
Gets the object type.
|
List<PartitionSchema> |
getPartitionSchemas()
Gets a list of partition schemas for this transformation.
|
String[] |
getPartitionSchemasNames()
Gets the partition schemas' names.
|
String |
getPathAndName()
Gets the repository directory path and name of the transformation.
|
PerformanceLogTable |
getPerformanceLogTable()
Gets the performance log table for the transformation.
|
org.pentaho.di.core.row.RowMetaInterface |
getPrevInfoFields(StepMeta stepMeta)
Find the informational fields coming from an informational step into the step specified.
|
org.pentaho.di.core.row.RowMetaInterface |
getPrevInfoFields(String stepname)
Find the informational fields coming from an informational step into the step specified.
|
org.pentaho.di.core.Result |
getPreviousResult()
Deprecated.
this was moved to Trans to keep the metadata stateless
|
org.pentaho.di.core.row.RowMetaInterface |
getPrevStepFields(StepMeta stepMeta)
Find the fields that are entering a certain step.
|
org.pentaho.di.core.row.RowMetaInterface |
getPrevStepFields(StepMeta stepMeta,
org.pentaho.di.core.ProgressMonitorListener monitor)
Find the fields that are entering a certain step.
|
org.pentaho.di.core.row.RowMetaInterface |
getPrevStepFields(String stepname)
Find the fields that are entering a step with a certain name.
|
String[] |
getPrevStepNames(StepMeta stepMeta)
Retrieve an array of preceding steps for a certain destination step.
|
String[] |
getPrevStepNames(String stepname)
Retrieve an array of succeeding step names for a certain originating step name.
|
StepMeta[] |
getPrevSteps(StepMeta stepMeta)
Retrieve an array of preceding steps for a certain destination step.
|
org.pentaho.di.repository.RepositoryObjectType |
getRepositoryElementType()
Gets the repository element type.
|
List<ResourceReference> |
getResourceDependencies()
Gets a list of the resource dependencies.
|
List<org.pentaho.di.core.ResultFile> |
getResultFiles()
Deprecated.
this was moved to Trans to keep the metadata stateless
|
List<org.pentaho.di.core.RowMetaAndData> |
getResultRows()
Deprecated.
Moved to Trans to make this class stateless
|
org.pentaho.di.core.gui.Point[] |
getSelectedNoteLocations()
Get an array of all the selected note locations.
|
org.pentaho.di.core.gui.Point[] |
getSelectedStepLocations()
Get an array of all the selected step locations.
|
String[] |
getSelectedStepNames()
Gets an array of all the selected step names.
|
List<StepMeta> |
getSelectedSteps()
Gets a list of the selected steps.
|
int |
getSizeRowset()
Gets the size of the rowsets.
|
SlaveStepCopyPartitionDistribution |
getSlaveStepCopyPartitionDistribution()
Gets the slave step copy partition distribution.
|
int |
getSleepTimeEmpty()
Gets the amount of time (in nano-seconds) to wait while the input buffer is empty.
|
int |
getSleepTimeFull()
Gets the amount of time (in nano-seconds) to wait while the input buffer is full.
|
List<org.pentaho.di.core.SQLStatement> |
getSQLStatements()
Builds a list of all the SQL statements that this transformation needs in order to work properly.
|
List<org.pentaho.di.core.SQLStatement> |
getSQLStatements(org.pentaho.di.core.ProgressMonitorListener monitor)
Builds a list of all the SQL statements that this transformation needs in order to work properly.
|
String |
getSQLStatementsString()
Get the SQL statements (needed to run this transformation) as a single String.
|
StepMeta |
getStep(int i)
Retrieves a step on a certain location (i.e.
|
StepMeta |
getStep(int x,
int y,
int iconsize)
Find the step that is located on a certain point on the canvas, taking into account the icon size.
|
org.pentaho.di.core.row.RowMetaInterface |
getStepFields(StepMeta stepMeta)
Returns the fields that are emitted by a certain step.
|
org.pentaho.di.core.row.RowMetaInterface |
getStepFields(StepMeta[] stepMeta)
Gets the fields for each of the specified steps and merges them into a single set
|
org.pentaho.di.core.row.RowMetaInterface |
getStepFields(StepMeta stepMeta,
org.pentaho.di.core.ProgressMonitorListener monitor)
Returns the fields that are emitted by a certain step.
|
org.pentaho.di.core.row.RowMetaInterface |
getStepFields(StepMeta stepMeta,
StepMeta targetStep,
org.pentaho.di.core.ProgressMonitorListener monitor)
Returns the fields that are emitted by a certain step.
|
org.pentaho.di.core.row.RowMetaInterface |
getStepFields(String stepname)
Returns the fields that are emitted by a certain step name.
|
int[] |
getStepIndexes(List<StepMeta> steps)
Gets an array of the locations of an array of steps.
|
StepLogTable |
getStepLogTable()
Gets the step log table for the transformation.
|
String[] |
getStepNames()
Gets the names of all the steps.
|
long |
getStepPerformanceCapturingDelay()
Gets the step performance capturing delay.
|
String |
getStepPerformanceCapturingSizeLimit()
Gets the step performance capturing size limit.
|
List<StepMeta> |
getSteps()
Get a list of defined steps in this transformation.
|
StepMeta[] |
getStepsArray()
Gets all the steps as an array.
|
List<StringSearchResult> |
getStringList(boolean searchSteps,
boolean searchDatabases,
boolean searchNotes)
Get a list of all the strings used in this transformation.
|
List<StringSearchResult> |
getStringList(boolean searchSteps,
boolean searchDatabases,
boolean searchNotes,
boolean includePasswords)
Gets a list of all the strings used in this transformation.
|
org.pentaho.di.core.row.RowMetaInterface |
getThisStepFields(StepMeta stepMeta,
StepMeta nextStep,
org.pentaho.di.core.row.RowMetaInterface row)
Returns the fields that are emitted by a step.
|
org.pentaho.di.core.row.RowMetaInterface |
getThisStepFields(StepMeta stepMeta,
StepMeta nextStep,
org.pentaho.di.core.row.RowMetaInterface row,
org.pentaho.di.core.ProgressMonitorListener monitor)
Returns the fields that are emitted by a step.
|
org.pentaho.di.core.row.RowMetaInterface |
getThisStepFields(String stepname,
org.pentaho.di.core.row.RowMetaInterface row)
Return the fields that are emitted by a step with a certain name.
|
TransMeta.TransformationType |
getTransformationType()
Gets the transformation type.
|
TransHopMeta |
getTransHop(int i)
Retrieves a hop on a certain location (i.e.
|
List<StepMeta> |
getTransHopSteps(boolean all)
Gets a List of all the steps that are used in at least one active hop.
|
TransLogTable |
getTransLogTable()
Gets the log table for the transformation.
|
int |
getTransstatus()
Gets the status of the transformation.
|
String |
getTransversion()
Gets the version of the transformation.
|
Map<String,String> |
getUsedArguments(String[] arguments)
Gets the arguments (and their values) used by this transformation.
|
List<StepMeta> |
getUsedSteps()
Gets the list of used steps, which are the steps that are connected by hops.
|
List<String> |
getUsedVariables()
Gets a list of the used variables in this transformation.
|
String |
getXML()
Gets the XML representation of this transformation.
|
String |
getXML(boolean includeSteps,
boolean includeDatabase,
boolean includeSlaves,
boolean includeClusters,
boolean includePartitions)
Gets the XML representation of this transformation, including or excluding step, database, slave server, cluster,
or partition information as specified by the parameters
|
boolean |
hasChanged()
Checks whether or not the transformation has changed.
|
boolean |
hasLoop(StepMeta stepMeta)
See if there are any loops in the transformation, starting at the indicated step.
|
boolean |
hasMissingPlugins() |
boolean |
hasRepositoryReferences()
Checks whether the transformation has repository references.
|
boolean |
haveClusterSchemasChanged()
Checks whether or not any of the clustering schemas have been changed.
|
boolean |
haveHopsChanged()
Checks whether or not any of the hops have been changed.
|
boolean |
havePartitionSchemasChanged()
Checks whether or not any of the partitioning schemas have been changed.
|
boolean |
haveStepsChanged()
Checks whether or not the steps have changed.
|
int |
indexOfStep(StepMeta stepMeta)
Finds the location (index) of the specified step.
|
int |
indexOfTransHop(TransHopMeta hi)
Finds the location (index) of the specified hop.
|
boolean |
isCapturingStepPerformanceSnapShots()
Checks whether the transformation is capturing step performance snapshots.
|
boolean |
isDatabaseConnectionUsed(org.pentaho.di.core.database.DatabaseMeta databaseMeta)
This method asks all steps in the transformation whether or not the specified database connection is used.
|
boolean |
isFeedbackShown()
Checks if is feedback shown.
|
boolean |
isFileReference()
Checks if the transformation is referenced by a file.
|
static boolean |
isFileReference(String exactFilename,
String exactTransname)
Checks (using the exact filename and transformation name) if the transformation is referenced by a file.
|
boolean |
isForcingSeparateLogging() |
boolean |
isGatheringMetrics() |
boolean |
isPrivateKey() |
boolean |
isRepReference()
Checks if the transformation is referenced by a repository.
|
static boolean |
isRepReference(String exactFilename,
String exactTransname)
Checks (using the exact filename and transformation name) if the transformation is referenced by a repository.
|
boolean |
isSlaveTransformation()
Checks whether the transformation is a slave transformation.
|
boolean |
isStepInformative(StepMeta this_step,
StepMeta prev_step)
Determines whether or not a certain step is informative.
|
boolean |
isStepUsedInTransHops(StepMeta stepMeta)
Checks if a step has been used in a hop or not.
|
boolean |
isUsingAClusterSchema()
Checks if the transformation is using a cluster schema.
|
boolean |
isUsingClusterSchema(ClusterSchema clusterSchema)
Checks if the transformation is using the specified cluster schema.
|
boolean |
isUsingPartitionSchema(PartitionSchema partitionSchema)
Checks if the transformation is using the specified partition schema.
|
boolean |
isUsingSlaveServer(SlaveServer slaveServer)
Checks if the transformation is using the specified slave server.
|
boolean |
isUsingThreadPriorityManagment()
Checks whether the transformation is using thread priority management.
|
boolean |
isUsingUniqueConnections()
Checks if the transformation is using unique database connections.
|
void |
loadXML(Node transnode,
Repository rep,
boolean setInternalVariables)
Parses an XML DOM (starting at the specified Node) that describes the transformation.
|
void |
loadXML(Node transnode,
Repository rep,
boolean setInternalVariables,
org.pentaho.di.core.variables.VariableSpace parentVariableSpace)
Parses an XML DOM (starting at the specified Node) that describes the transformation.
|
void |
loadXML(Node transnode,
Repository rep,
boolean setInternalVariables,
org.pentaho.di.core.variables.VariableSpace parentVariableSpace,
org.pentaho.di.core.gui.OverwritePrompter prompter)
Parses an XML DOM (starting at the specified Node) that describes the transformation.
|
void |
loadXML(Node transnode,
String fname,
org.pentaho.metastore.api.IMetaStore metaStore,
Repository rep,
boolean setInternalVariables,
org.pentaho.di.core.variables.VariableSpace parentVariableSpace,
org.pentaho.di.core.gui.OverwritePrompter prompter)
Parses an XML DOM (starting at the specified Node) that describes the transformation.
|
void |
loadXML(Node transnode,
String fname,
Repository rep,
boolean setInternalVariables,
org.pentaho.di.core.variables.VariableSpace parentVariableSpace,
org.pentaho.di.core.gui.OverwritePrompter prompter)
Parses an XML DOM (starting at the specified Node) that describes the transformation.
|
void |
lookupRepositoryReferences(Repository repository)
Looks up the references after a repository import.
|
void |
notifyAllListeners(StepMeta oldMeta,
StepMeta newMeta) |
int |
nrDependencies()
Gets the number of dependencies in the transformation.
|
int |
nrStepChangeListeners()
Gets the number of stepChangeListeners in the transformation.
|
int |
nrSteps()
Gets the number of steps in the transformation.
|
int |
nrTransHops()
Gets the number of hops in the transformation.
|
boolean |
partOfTransHop(StepMeta stepMeta)
Determines whether or not a certain step is part of a hop.
|
SharedObjects |
readSharedObjects()
Reads the shared objects (steps, connections, etc.).
|
Object |
realClone(boolean doClear)
Perform a real clone of the transformation meta-data object, including cloning all lists and copying all values.
|
void |
removeAllDependencies()
Clears all the dependencies from the transformation.
|
void |
removeDependency(int i)
Removes a dependency from the transformation on a certain location (i.e.
|
void |
removeMissingTrans(MissingTrans trans) |
void |
removeStep(int i)
Removes a step from the transformation on a certain location (i.e.
|
void |
removeStepChangeListener(StepMetaChangeListenerInterface list) |
void |
removeTransHop(int i)
Removes a hop from the transformation on a certain location (i.e.
|
void |
removeTransHop(TransHopMeta hop)
Removes a hop from the transformation.
|
void |
saveMetaStoreObjects(Repository repository,
org.pentaho.metastore.api.IMetaStore metaStore)
This method needs to be called to store those objects which are used and referenced in the transformation metadata
but not saved in the XML serialization.
|
void |
saveSharedObjects()
Save shared objects, including databases, steps, partition schemas, slave servers, and cluster schemas, to a file
|
void |
selectAll()
Mark all steps in the transformation as selected.
|
void |
setArguments(String[] arguments)
Deprecated.
moved to Trans
|
void |
setCapturingStepPerformanceSnapShots(boolean capturingStepPerformanceSnapShots)
Sets whether the transformation is capturing step performance snapshots.
|
void |
setClusterSchemas(List<ClusterSchema> clusterSchemas)
Sets list of the cluster schemas used by the transformation.
|
void |
setCounters(Hashtable<String,org.pentaho.di.core.Counter> counters)
Deprecated.
moved to Trans
|
void |
setDbCache(org.pentaho.di.core.DBCache dbCache)
Sets the database cache object.
|
void |
setDependencies(List<TransDependency> dependencies)
Sets the dependencies for the transformation.
|
void |
setFeedbackShown(boolean feedbackShown)
Sets whether the feedback should be shown.
|
void |
setFeedbackSize(int feedbackSize)
Sets the feedback size.
|
void |
setForcingSeparateLogging(boolean forcingSeparateLogging) |
void |
setGatheringMetrics(boolean gatheringMetrics) |
void |
setInternalKettleVariables(org.pentaho.di.core.variables.VariableSpace var)
Sets the internal kettle variables.
|
void |
setKey(byte[] key) |
void |
setMaxDateConnection(org.pentaho.di.core.database.DatabaseMeta maxDateConnection)
Sets the database connection associated with "max date" processing.
|
void |
setMaxDateDifference(double maxDateDifference)
Sets the maximum date difference between start and end dates for row/record processing.
|
void |
setMaxDateField(String maxDateField)
Sets the date field associated with "max date" processing.
|
void |
setMaxDateOffset(double maxDateOffset)
Sets the amount by which to increase the end date in "max date" processing.
|
void |
setMaxDateTable(String maxDateTable)
Sets the table name associated with "max date" processing.
|
void |
setMetricsLogTable(MetricsLogTable metricsLogTable) |
void |
setPartitionSchemas(List<PartitionSchema> partitionSchemas)
Sets the list of partition schemas for this transformation.
|
void |
setPerformanceLogTable(PerformanceLogTable performanceLogTable)
Sets the performance log table for the transformation.
|
void |
setPreviousResult(org.pentaho.di.core.Result previousResult)
Deprecated.
this was moved to Trans to keep the metadata stateless
|
void |
setPrivateKey(boolean privateKey) |
void |
setResultFiles(List<org.pentaho.di.core.ResultFile> resultFiles)
Deprecated.
this was moved to Trans to keep the metadata stateless
|
void |
setResultRows(List<org.pentaho.di.core.RowMetaAndData> resultRows)
Deprecated.
Moved to Trans to make this class stateless
|
void |
setSizeRowset(int sizeRowset)
Sets the size of the rowsets.
|
void |
setSlaveStepCopyPartitionDistribution(SlaveStepCopyPartitionDistribution slaveStepCopyPartitionDistribution)
Sets the slave step copy partition distribution.
|
void |
setSlaveTransformation(boolean slaveTransformation)
Sets whether the transformation is a slave transformation.
|
void |
setSleepTimeEmpty(int sleepTimeEmpty)
Sets the amount of time (in nano-seconds) to wait while the input buffer is empty.
|
void |
setSleepTimeFull(int sleepTimeFull)
Sets the amount of time (in nano-seconds) to wait while the input buffer is full.
|
void |
setStep(int i,
StepMeta stepMeta)
Changes the content of a step on a certain position.
|
void |
setStepLogTable(StepLogTable stepLogTable)
Sets the step log table for the transformation.
|
void |
setStepPerformanceCapturingDelay(long stepPerformanceCapturingDelay)
Sets the step performance capturing delay.
|
void |
setStepPerformanceCapturingSizeLimit(String stepPerformanceCapturingSizeLimit)
Sets the step performance capturing size limit.
|
void |
setTransformationType(TransMeta.TransformationType transformationType)
Sets the transformation type.
|
void |
setTransHop(int i,
TransHopMeta hi)
Changes the content of a hop on a certain position.
|
void |
setTransLogTable(TransLogTable transLogTable)
Sets the log table for the transformation.
|
void |
setTransstatus(int n)
Sets the status of the transformation.
|
void |
setTransversion(String n)
Sets the version of the transformation.
|
void |
setUsingThreadPriorityManagment(boolean usingThreadPriorityManagment)
Sets whether the transformation is using thread priority management.
|
void |
setUsingUniqueConnections(boolean usingUniqueConnections)
Sets whether the transformation is using unique database connections.
|
void |
sortHops()
Sorts all the hops in the transformation.
|
void |
sortHopsNatural()
Sorts the hops in a natural way: from beginning to end.
|
void |
sortSteps()
Puts the steps in alphabetical order.
|
Map<StepMeta,Map<StepMeta,Boolean>> |
sortStepsNatural()
Puts the steps in a more natural order: from start to finish.
|
String |
toString()
Gets a textual representation of the transformation.
|
void |
unselectAll()
Clear the selection of all steps.
|
void |
writeXML(String filename)
Utility method to write the XML of this transformation to a file, mostly for testing purposes.
|
activateParameters, addContentChangedListener, addDatabase, addDatabase, addFilenameChangedListener, addNameChangedListener, addNote, addNote, addObserver, addOrReplaceDatabase, addOrReplaceSlaveServer, addParameterDefinition, addUndo, canSave, clearChangedDatabases, clearParameters, clearUndo, copyParametersFrom, copyVariablesFrom, deleteObserver, environmentSubstitute, environmentSubstitute, eraseParameters, fieldSubstitute, findDatabase, findSlaveServer, getAttribute, getAttributes, getAttributesMap, getBooleanValueOfVariable, getChannelLogTable, getContainerObjectId, getContentChangedListeners, getCreatedDate, getCreatedUser, getDatabase, getDatabaseNames, getDatabases, getDescription, getEmbeddedMetaStore, getExtendedDescription, getFilename, getLogLevel, getMaxUndo, getMetaStore, getModifiedDate, getModifiedUser, getName, getNote, getNote, getNoteIndexes, getNotes, getObjectCopy, getObjectId, getObjectName, getObjectRevision, getParameterDefault, getParameterDescription, getParameterValue, getParent, getParentVariableSpace, getPrivateDatabases, getRegistrationDate, getRepository, getRepositoryDirectory, getSelectedNotes, getSharedObjects, getSharedObjectsFile, getSlaveServerNames, getSlaveServers, getUndoSize, getVariable, getVariable, haveConnectionsChanged, haveNotesChanged, importFromMetaStore, indexOfDatabase, indexOfNote, initializeVariablesFrom, injectVariables, isAlwaysShowRunOptions, isShowDialog, listParameters, listVariables, lowerNote, nameFromFilename, nextUndo, notifyObservers, nrDatabases, nrNotes, previousUndo, raiseNote, removeContentChangedListener, removeDatabase, removeFilenameChangedListener, removeNameChangedListener, removeNote, setAlwaysShowRunOptions, setAttribute, setAttributes, setAttributesMap, setCarteObjectId, setChanged, setChanged, setChannelLogTable, setCreatedDate, setCreatedUser, setDatabases, setDescription, setExtendedDescription, setFilename, setInternalKettleVariables, setLogLevel, setMaxUndo, setMetaStore, setModifiedDate, setModifiedUser, setName, setObjectId, setObjectRevision, setParameterValue, setParentVariableSpace, setPrivateDatabases, setRepository, setRepositoryDirectory, setSharedObjects, setSharedObjectsFile, setShowDialog, setSlaveServers, setVariable, shareVariablesWith, viewNextUndo, viewPreviousUndo, viewThisUndo
getClass, hashCode, notify, notifyAll, wait, wait, wait
getDescription, getName, getObjectId, getObjectRevision, getRepositoryDirectory, setDescription, setName, setObjectId, setObjectRevision, setRepositoryDirectory
getContainerObjectId, getFilename, getLogLevel, getObjectCopy, getObjectId, getObjectName, getObjectRevision, getParent, getRegistrationDate, getRepositoryDirectory
getRepositoryDirectory
public static final String XML_TAG
public static final String STRING_TRANSMETA
public static final org.pentaho.di.repository.RepositoryObjectType REPOSITORY_ELEMENT_TYPE
public static final int BORDER_INDENT
public static final String[] desc_type_undo
public static final String XML_TAG_ORDER
public static final String XML_TAG_NOTEPADS
public static final String XML_TAG_PARAMETERS
public static final String XML_TAG_PARTITIONSCHEMAS
public static final String XML_TAG_SLAVESERVERS
public static final String XML_TAG_CLUSTERSCHEMAS
public static final String XML_TAG_STEP_ERROR_HANDLING
public TransMeta()
public TransMeta(org.pentaho.di.core.variables.VariableSpace parent)
parent
- the variable space to inherit from@Deprecated public TransMeta(String filename, String name, String[] arguments)
filename
- The filename of the transformationname
- The name of the transformationarguments
- The arguments as Stringspublic TransMeta(String fname) throws org.pentaho.di.core.exception.KettleXMLException, org.pentaho.di.core.exception.KettleMissingPluginsException
fname
- The filenameorg.pentaho.di.core.exception.KettleXMLException
- if any errors occur during parsing of the specified fileorg.pentaho.di.core.exception.KettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public TransMeta(String fname, org.pentaho.di.core.variables.VariableSpace parentVariableSpace) throws org.pentaho.di.core.exception.KettleXMLException, org.pentaho.di.core.exception.KettleMissingPluginsException
fname
- The filenameparentVariableSpace
- the parent variable spaceorg.pentaho.di.core.exception.KettleXMLException
- if any errors occur during parsing of the specified fileorg.pentaho.di.core.exception.KettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public TransMeta(String fname, boolean setInternalVariables) throws org.pentaho.di.core.exception.KettleXMLException, org.pentaho.di.core.exception.KettleMissingPluginsException
fname
- The filenamesetInternalVariables
- true if you want to set the internal variables based on this transformation informationorg.pentaho.di.core.exception.KettleXMLException
- if any errors occur during parsing of the specified fileorg.pentaho.di.core.exception.KettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public TransMeta(String fname, Repository rep) throws org.pentaho.di.core.exception.KettleXMLException, org.pentaho.di.core.exception.KettleMissingPluginsException
fname
- The filenamerep
- The repository to load the default set of connections from, null if no repository is availableorg.pentaho.di.core.exception.KettleXMLException
- if any errors occur during parsing of the specified fileorg.pentaho.di.core.exception.KettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public TransMeta(String fname, Repository rep, boolean setInternalVariables) throws org.pentaho.di.core.exception.KettleXMLException, org.pentaho.di.core.exception.KettleMissingPluginsException
fname
- The filenamerep
- The repository to load the default set of connections from, null if no repository is availablesetInternalVariables
- true if you want to set the internal variables based on this transformation informationorg.pentaho.di.core.exception.KettleXMLException
- if any errors occur during parsing of the specified fileorg.pentaho.di.core.exception.KettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public TransMeta(String fname, Repository rep, boolean setInternalVariables, org.pentaho.di.core.variables.VariableSpace parentVariableSpace) throws org.pentaho.di.core.exception.KettleXMLException, org.pentaho.di.core.exception.KettleMissingPluginsException
fname
- The filenamerep
- The repository to load the default set of connections from, null if no repository is availablesetInternalVariables
- true if you want to set the internal variables based on this transformation informationparentVariableSpace
- the parent variable space to use during TransMeta constructionorg.pentaho.di.core.exception.KettleXMLException
- if any errors occur during parsing of the specified fileorg.pentaho.di.core.exception.KettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public TransMeta(String fname, Repository rep, boolean setInternalVariables, org.pentaho.di.core.variables.VariableSpace parentVariableSpace, org.pentaho.di.core.gui.OverwritePrompter prompter) throws org.pentaho.di.core.exception.KettleXMLException, org.pentaho.di.core.exception.KettleMissingPluginsException
fname
- The filenamerep
- The repository to load the default set of connections from, null if no repository is availablesetInternalVariables
- true if you want to set the internal variables based on this transformation informationparentVariableSpace
- the parent variable space to use during TransMeta constructionprompter
- the changed/replace listener or null if there is noneorg.pentaho.di.core.exception.KettleXMLException
- if any errors occur during parsing of the specified fileorg.pentaho.di.core.exception.KettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public TransMeta(String fname, org.pentaho.metastore.api.IMetaStore metaStore, Repository rep, boolean setInternalVariables, org.pentaho.di.core.variables.VariableSpace parentVariableSpace, org.pentaho.di.core.gui.OverwritePrompter prompter) throws org.pentaho.di.core.exception.KettleXMLException, org.pentaho.di.core.exception.KettleMissingPluginsException
fname
- The filenamemetaStore
- the metadata store to reference (or null if there is none)rep
- The repository to load the default set of connections from, null if no repository is availablesetInternalVariables
- true if you want to set the internal variables based on this transformation informationparentVariableSpace
- the parent variable space to use during TransMeta constructionprompter
- the changed/replace listener or null if there is noneorg.pentaho.di.core.exception.KettleXMLException
- if any errors occur during parsing of the specified fileorg.pentaho.di.core.exception.KettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public TransMeta(InputStream xmlStream, Repository rep, boolean setInternalVariables, org.pentaho.di.core.variables.VariableSpace parentVariableSpace, org.pentaho.di.core.gui.OverwritePrompter prompter) throws org.pentaho.di.core.exception.KettleXMLException, org.pentaho.di.core.exception.KettleMissingPluginsException
xmlStream
- the XML input stream from which to read the transformation definitionrep
- the repositorysetInternalVariables
- whether to set internal variables as a result of the creationparentVariableSpace
- the parent variable spaceprompter
- a GUI component that will prompt the user if the new transformation will overwrite an existing oneorg.pentaho.di.core.exception.KettleXMLException
- if any errors occur during parsing of the specified streamorg.pentaho.di.core.exception.KettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public TransMeta(Node transnode, Repository rep) throws org.pentaho.di.core.exception.KettleXMLException, org.pentaho.di.core.exception.KettleMissingPluginsException
transnode
- The XML node to load fromrep
- the repository to reference.org.pentaho.di.core.exception.KettleXMLException
- if any errors occur during parsing of the specified fileorg.pentaho.di.core.exception.KettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public int compare(TransMeta t1, TransMeta t2)
compare
in interface Comparator<TransMeta>
t1
- the first transformation to comparet2
- the second transformation to comparepublic int compareTo(TransMeta o)
compareTo
in interface Comparable<TransMeta>
o
- the ocompare(TransMeta, TransMeta)
,
Comparable.compareTo(java.lang.Object)
public boolean equals(Object obj)
equals
in interface Comparator<TransMeta>
equals
in class Object
obj
- the objcompare(TransMeta, TransMeta)
,
Object.equals(java.lang.Object)
public Object clone()
clone
in class Object
Object.clone()
public Object realClone(boolean doClear)
doClear
- Whether to clear all of the clone's data before copying from the source objectpublic void clear()
clear
in class AbstractMeta
public void addStep(StepMeta stepMeta)
stepMeta
- The meta-data for the step to be added.public void addOrReplaceStep(StepMeta stepMeta)
stepMeta
- The meta-data for the step to be added.public void addTransHop(TransHopMeta hi)
hi
- The hop meta-data to be added.public void addDependency(TransDependency td)
td
- The transformation dependency to be added.public void addStep(int p, StepMeta stepMeta)
p
- The index into the step liststepMeta
- The step to be added.public void addTransHop(int p, TransHopMeta hi)
p
- the index into the hop listhi
- The hop to be added.public void addDependency(int p, TransDependency td)
p
- The index into the dependencies list.td
- The transformation dependency to be added.public List<StepMeta> getSteps()
public StepMeta getStep(int i)
i
- The index into the steps list.public TransHopMeta getTransHop(int i)
i
- The index into the hops list.public TransDependency getDependency(int i)
i
- The index into the dependencies list.public void removeStep(int i)
i
- The indexpublic void removeTransHop(int i)
i
- The index into the hops listpublic void removeTransHop(TransHopMeta hop)
hop
- The hop to remove from the list of hopspublic void removeDependency(int i)
i
- The locationpublic void removeAllDependencies()
public int nrSteps()
public int nrTransHops()
public int nrDependencies()
public int nrStepChangeListeners()
public void setStep(int i, StepMeta stepMeta)
i
- The index into the steps liststepMeta
- The step meta-data to setpublic void setTransHop(int i, TransHopMeta hi)
i
- The index into the hops listhi
- The hop meta-data to setpublic List<StepMeta> getUsedSteps()
public StepMeta findStep(String name)
name
- The name of the step to look forpublic StepMeta findStep(String name, StepMeta exclude)
name
- The name of the step to look forexclude
- The step information to exclude.public TransHopMeta findTransHop(String name)
name
- The name of the hop to look forpublic TransHopMeta findTransHopFrom(StepMeta fromstep)
fromstep
- The step at the start of the hop.public TransHopMeta findTransHop(TransHopMeta hi)
hi
- The hop information to look for.public TransHopMeta findTransHop(StepMeta from, StepMeta to)
from
- The step at the start of the hop.to
- The step at the end of the hop.public TransHopMeta findTransHop(StepMeta from, StepMeta to, boolean disabledToo)
from
- The step at the start of the hop.to
- The step at the end of the hop.disabledToo
- the disabled toopublic TransHopMeta findTransHopTo(StepMeta tostep)
tostep
- The step at the end of the hop.public boolean isStepInformative(StepMeta this_step, StepMeta prev_step)
this_step
- The step that is receiving information.prev_step
- The step that is sending information@Deprecated public int findNrPrevSteps(String stepname)
stepname
- The name of the step to start from@Deprecated public int findNrPrevSteps(String stepname, boolean info)
stepname
- The name of the step to start frominfo
- true if only the informational steps are desired, false otherwisepublic int findNrPrevSteps(StepMeta stepMeta)
stepMeta
- The source step@Deprecated public StepMeta findPrevStep(String stepname, int nr)
stepname
- The source step namenr
- the index into the step list@Deprecated public StepMeta findPrevStep(String stepname, int nr, boolean info)
stepname
- The name of the stepnr
- The index into the step listinfo
- true if only the informational steps are desired, false otherwisepublic StepMeta findPrevStep(StepMeta stepMeta, int nr)
stepMeta
- The source step informationnr
- the index into the hops list@Deprecated public int findNrPrevSteps(StepMeta stepMeta, boolean info)
stepMeta
- The name of the stepinfo
- true if only the informational steps are desired, false otherwise@Deprecated public StepMeta findPrevStep(StepMeta stepMeta, int nr, boolean info)
stepMeta
- The stepnr
- The index into the hops listinfo
- true if we only want the informational steps.public List<StepMeta> findPreviousSteps(StepMeta stepMeta)
stepMeta
- The reference steppublic List<StepMeta> findPreviousSteps(StepMeta stepMeta, boolean info)
stepMeta
- The name of the stepinfo
- true if we only want the informational steps.public StepMeta[] getInfoStep(StepMeta stepMeta)
stepMeta
- The name of the steppublic int findNrInfoSteps(StepMeta stepMeta)
stepMeta
- The steppublic org.pentaho.di.core.row.RowMetaInterface getPrevInfoFields(String stepname) throws org.pentaho.di.core.exception.KettleStepException
stepname
- The name of the steporg.pentaho.di.core.exception.KettleStepException
- the kettle step exceptionpublic org.pentaho.di.core.row.RowMetaInterface getPrevInfoFields(StepMeta stepMeta) throws org.pentaho.di.core.exception.KettleStepException
stepMeta
- The receiving steporg.pentaho.di.core.exception.KettleStepException
- the kettle step exception@Deprecated public int findNrNextSteps(StepMeta stepMeta)
stepMeta
- The originating step@Deprecated public StepMeta findNextStep(StepMeta stepMeta, int nr)
stepMeta
- The originating stepnr
- The locationpublic StepMeta[] getPrevSteps(StepMeta stepMeta)
stepMeta
- The destination steppublic String[] getPrevStepNames(String stepname)
stepname
- The originating step namepublic String[] getPrevStepNames(StepMeta stepMeta)
stepMeta
- The destination step@Deprecated public StepMeta[] getNextSteps(StepMeta stepMeta)
stepMeta
- The originating steppublic List<StepMeta> findNextSteps(StepMeta stepMeta)
stepMeta
- The originating steppublic String[] getNextStepNames(StepMeta stepMeta)
stepMeta
- The originating steppublic StepMeta getStep(int x, int y, int iconsize)
x
- the x-coordinate of the point queriedy
- the y-coordinate of the point queriediconsize
- the iconsizepublic boolean partOfTransHop(StepMeta stepMeta)
stepMeta
- The step queriedpublic org.pentaho.di.core.row.RowMetaInterface getStepFields(String stepname) throws org.pentaho.di.core.exception.KettleStepException
stepname
- The stepname of the step to be queried.org.pentaho.di.core.exception.KettleStepException
- the kettle step exceptionpublic org.pentaho.di.core.row.RowMetaInterface getStepFields(StepMeta stepMeta) throws org.pentaho.di.core.exception.KettleStepException
stepMeta
- The step to be queried.org.pentaho.di.core.exception.KettleStepException
- the kettle step exceptionpublic org.pentaho.di.core.row.RowMetaInterface getStepFields(StepMeta[] stepMeta) throws org.pentaho.di.core.exception.KettleStepException
stepMeta
- the step metaorg.pentaho.di.core.exception.KettleStepException
- the kettle step exceptionpublic org.pentaho.di.core.row.RowMetaInterface getStepFields(StepMeta stepMeta, org.pentaho.di.core.ProgressMonitorListener monitor) throws org.pentaho.di.core.exception.KettleStepException
stepMeta
- The step to be queried.monitor
- The progress monitor for progress dialog. (null if not used!)org.pentaho.di.core.exception.KettleStepException
- the kettle step exceptionpublic org.pentaho.di.core.row.RowMetaInterface getStepFields(StepMeta stepMeta, StepMeta targetStep, org.pentaho.di.core.ProgressMonitorListener monitor) throws org.pentaho.di.core.exception.KettleStepException
stepMeta
- The step to be queried.targetStep
- the target stepmonitor
- The progress monitor for progress dialog. (null if not used!)org.pentaho.di.core.exception.KettleStepException
- the kettle step exceptionpublic org.pentaho.di.core.row.RowMetaInterface getPrevStepFields(String stepname) throws org.pentaho.di.core.exception.KettleStepException
stepname
- The name of the step queriedorg.pentaho.di.core.exception.KettleStepException
- the kettle step exceptionpublic org.pentaho.di.core.row.RowMetaInterface getPrevStepFields(StepMeta stepMeta) throws org.pentaho.di.core.exception.KettleStepException
stepMeta
- The step queriedorg.pentaho.di.core.exception.KettleStepException
- the kettle step exceptionpublic org.pentaho.di.core.row.RowMetaInterface getPrevStepFields(StepMeta stepMeta, org.pentaho.di.core.ProgressMonitorListener monitor) throws org.pentaho.di.core.exception.KettleStepException
stepMeta
- The step queriedmonitor
- The progress monitor for progress dialog. (null if not used!)org.pentaho.di.core.exception.KettleStepException
- the kettle step exceptionpublic org.pentaho.di.core.row.RowMetaInterface getThisStepFields(String stepname, org.pentaho.di.core.row.RowMetaInterface row) throws org.pentaho.di.core.exception.KettleStepException
stepname
- The name of the step that's being queried.row
- A row containing the input fields or an empty row if no input is required.org.pentaho.di.core.exception.KettleStepException
- the kettle step exceptionpublic org.pentaho.di.core.row.RowMetaInterface getThisStepFields(StepMeta stepMeta, StepMeta nextStep, org.pentaho.di.core.row.RowMetaInterface row) throws org.pentaho.di.core.exception.KettleStepException
stepMeta
- : The StepMeta object that's being queriednextStep
- : if non-null this is the next step that's call back to ask what's being sentrow
- : A row containing the input fields or an empty row if no input is required.org.pentaho.di.core.exception.KettleStepException
- the kettle step exceptionpublic org.pentaho.di.core.row.RowMetaInterface getThisStepFields(StepMeta stepMeta, StepMeta nextStep, org.pentaho.di.core.row.RowMetaInterface row, org.pentaho.di.core.ProgressMonitorListener monitor) throws org.pentaho.di.core.exception.KettleStepException
stepMeta
- : The StepMeta object that's being queriednextStep
- : if non-null this is the next step that's call back to ask what's being sentrow
- : A row containing the input fields or an empty row if no input is required.monitor
- the monitororg.pentaho.di.core.exception.KettleStepException
- the kettle step exceptionpublic boolean isUsingPartitionSchema(PartitionSchema partitionSchema)
partitionSchema
- the partition schemapublic boolean isUsingAClusterSchema()
public boolean isUsingClusterSchema(ClusterSchema clusterSchema)
clusterSchema
- the cluster schema to checkpublic boolean isUsingSlaveServer(SlaveServer slaveServer) throws org.pentaho.di.core.exception.KettleException
slaveServer
- the slave serverorg.pentaho.di.core.exception.KettleException
- if any errors occur while checking for the slave serverpublic boolean isRepReference()
public boolean isFileReference()
isRepReference()
public static boolean isRepReference(String exactFilename, String exactTransname)
exactFilename
- the exact filenameexactTransname
- the exact transformation namepublic static boolean isFileReference(String exactFilename, String exactTransname)
exactFilename
- the exact filenameexactTransname
- the exact transformation nameisRepReference(String, String)
public int indexOfTransHop(TransHopMeta hi)
hi
- The hop queriedpublic int indexOfStep(StepMeta stepMeta)
stepMeta
- The step queriedpublic String getFileType()
getFileType
in interface EngineMetaInterface
EngineMetaInterface.getFileType()
public String[] getFilterNames()
getFilterNames
in interface EngineMetaInterface
EngineMetaInterface.getFilterNames()
public String[] getFilterExtensions()
Const.STRING_TRANS_FILTER_EXT
getFilterExtensions
in interface EngineMetaInterface
EngineMetaInterface.getFilterExtensions()
public String getDefaultExtension()
Const.STRING_TRANS_DEFAULT_EXT
getDefaultExtension
in interface EngineMetaInterface
EngineMetaInterface.getDefaultExtension()
public String getXML() throws org.pentaho.di.core.exception.KettleException
getXML
in interface EngineMetaInterface
getXML
in interface org.pentaho.di.core.xml.XMLInterface
org.pentaho.di.core.exception.KettleException
- if any errors occur during generation of the XMLXMLInterface.getXML()
public String getXML(boolean includeSteps, boolean includeDatabase, boolean includeSlaves, boolean includeClusters, boolean includePartitions) throws org.pentaho.di.core.exception.KettleException
includeSteps
- whether to include step dataincludeDatabase
- whether to include database dataincludeSlaves
- whether to include slave server dataincludeClusters
- whether to include cluster dataincludePartitions
- whether to include partition dataorg.pentaho.di.core.exception.KettleException
- if any errors occur during generation of the XMLpublic void loadXML(Node transnode, Repository rep, boolean setInternalVariables) throws org.pentaho.di.core.exception.KettleXMLException, org.pentaho.di.core.exception.KettleMissingPluginsException
transnode
- The XML node to load fromrep
- The repository to load the default list of database connections from (null if no repository is available)setInternalVariables
- true if you want to set the internal variables based on this transformation informationorg.pentaho.di.core.exception.KettleXMLException
- if any errors occur during parsing of the specified fileorg.pentaho.di.core.exception.KettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public void loadXML(Node transnode, Repository rep, boolean setInternalVariables, org.pentaho.di.core.variables.VariableSpace parentVariableSpace) throws org.pentaho.di.core.exception.KettleXMLException, org.pentaho.di.core.exception.KettleMissingPluginsException
transnode
- The XML node to load fromrep
- The repository to load the default list of database connections from (null if no repository is available)setInternalVariables
- true if you want to set the internal variables based on this transformation informationparentVariableSpace
- the parent variable space to use during TransMeta constructionorg.pentaho.di.core.exception.KettleXMLException
- if any errors occur during parsing of the specified fileorg.pentaho.di.core.exception.KettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public void loadXML(Node transnode, Repository rep, boolean setInternalVariables, org.pentaho.di.core.variables.VariableSpace parentVariableSpace, org.pentaho.di.core.gui.OverwritePrompter prompter) throws org.pentaho.di.core.exception.KettleXMLException, org.pentaho.di.core.exception.KettleMissingPluginsException
transnode
- The XML node to load fromrep
- The repository to load the default list of database connections from (null if no repository is available)setInternalVariables
- true if you want to set the internal variables based on this transformation informationparentVariableSpace
- the parent variable space to use during TransMeta constructionprompter
- the changed/replace listener or null if there is noneorg.pentaho.di.core.exception.KettleXMLException
- if any errors occur during parsing of the specified fileorg.pentaho.di.core.exception.KettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public void loadXML(Node transnode, String fname, Repository rep, boolean setInternalVariables, org.pentaho.di.core.variables.VariableSpace parentVariableSpace, org.pentaho.di.core.gui.OverwritePrompter prompter) throws org.pentaho.di.core.exception.KettleXMLException, org.pentaho.di.core.exception.KettleMissingPluginsException
transnode
- The XML node to load fromfname
- The filenamerep
- The repository to load the default list of database connections from (null if no repository is available)setInternalVariables
- true if you want to set the internal variables based on this transformation informationparentVariableSpace
- the parent variable space to use during TransMeta constructionprompter
- the changed/replace listener or null if there is noneorg.pentaho.di.core.exception.KettleXMLException
- if any errors occur during parsing of the specified fileorg.pentaho.di.core.exception.KettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public void loadXML(Node transnode, String fname, org.pentaho.metastore.api.IMetaStore metaStore, Repository rep, boolean setInternalVariables, org.pentaho.di.core.variables.VariableSpace parentVariableSpace, org.pentaho.di.core.gui.OverwritePrompter prompter) throws org.pentaho.di.core.exception.KettleXMLException, org.pentaho.di.core.exception.KettleMissingPluginsException
transnode
- The XML node to load fromfname
- The filenamerep
- The repository to load the default list of database connections from (null if no repository is available)setInternalVariables
- true if you want to set the internal variables based on this transformation informationparentVariableSpace
- the parent variable space to use during TransMeta constructionprompter
- the changed/replace listener or null if there is noneorg.pentaho.di.core.exception.KettleXMLException
- if any errors occur during parsing of the specified fileorg.pentaho.di.core.exception.KettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public byte[] getKey()
public void setKey(byte[] key)
public boolean isPrivateKey()
public void setPrivateKey(boolean privateKey)
public SharedObjects readSharedObjects() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
- if any errors occur while reading the shared objectspublic List<StepMeta> getTransHopSteps(boolean all)
all
- true if you want to get ALL the steps from the transformation, false otherwisepublic boolean isStepUsedInTransHops(StepMeta stepMeta)
stepMeta
- The step queried.public void clearChanged()
clearChanged
in interface ChangedFlagInterface
clearChanged
in interface EngineMetaInterface
clearChanged
in class AbstractMeta
public boolean haveStepsChanged()
public boolean haveHopsChanged()
public boolean havePartitionSchemasChanged()
public boolean haveClusterSchemasChanged()
public boolean hasChanged()
hasChanged
in interface ChangedFlagInterface
hasChanged
in class AbstractMeta
public boolean hasLoop(StepMeta stepMeta)
stepMeta
- The step position to start lookingpublic void selectAll()
public void unselectAll()
public org.pentaho.di.core.gui.Point[] getSelectedStepLocations()
public org.pentaho.di.core.gui.Point[] getSelectedNoteLocations()
public List<StepMeta> getSelectedSteps()
public String[] getSelectedStepNames()
public int[] getStepIndexes(List<StepMeta> steps)
steps
- An array of stepspublic org.pentaho.di.core.gui.Point getMaximum()
public org.pentaho.di.core.gui.Point getMinimum()
public String[] getStepNames()
public StepMeta[] getStepsArray()
public boolean findPrevious(StepMeta startStep, StepMeta stepToFind)
startStep
- The starting stepstepToFind
- The step to look for backward in the transformationpublic void sortSteps()
public void sortHops()
public Map<StepMeta,Map<StepMeta,Boolean>> sortStepsNatural()
public void sortHopsNatural()
public void analyseImpact(List<DatabaseImpact> impact, org.pentaho.di.core.ProgressMonitorListener monitor) throws org.pentaho.di.core.exception.KettleStepException
impact
- An ArrayList of DatabaseImpact objects.monitor
- a progress monitor listener to be updated as the transformation is analyzedorg.pentaho.di.core.exception.KettleStepException
- if any errors occur during analysispublic String getAlternativeStepname(String stepname)
stepname
- The stepname to find an alternative forpublic List<org.pentaho.di.core.SQLStatement> getSQLStatements() throws org.pentaho.di.core.exception.KettleStepException
org.pentaho.di.core.exception.KettleStepException
- if any errors occur during SQL statement generationpublic List<org.pentaho.di.core.SQLStatement> getSQLStatements(org.pentaho.di.core.ProgressMonitorListener monitor) throws org.pentaho.di.core.exception.KettleStepException
monitor
- a progress monitor listener to be updated as the SQL statements are generatedorg.pentaho.di.core.exception.KettleStepException
- if any errors occur during SQL statement generationpublic String getSQLStatementsString() throws org.pentaho.di.core.exception.KettleStepException
org.pentaho.di.core.exception.KettleStepException
- if any errors occur during SQL statement generation@Deprecated public void checkSteps(List<org.pentaho.di.core.CheckResultInterface> remarks, boolean only_selected, org.pentaho.di.core.ProgressMonitorListener monitor)
remarks
- The remarks list to add to.only_selected
- true to check only the selected steps, false for all stepsmonitor
- a progress monitor listener to be updated as the SQL statements are generatedpublic void checkSteps(List<org.pentaho.di.core.CheckResultInterface> remarks, boolean only_selected, org.pentaho.di.core.ProgressMonitorListener monitor, org.pentaho.di.core.variables.VariableSpace space, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore)
remarks
- The remarks list to add to.only_selected
- true to check only the selected steps, false for all stepsmonitor
- a progress monitor listener to be updated as the SQL statements are generated@Deprecated public List<org.pentaho.di.core.RowMetaAndData> getResultRows()
@Deprecated public void setResultRows(List<org.pentaho.di.core.RowMetaAndData> resultRows)
resultRows
- The list of result rows to set.public String getPathAndName()
@Deprecated public String[] getArguments()
@Deprecated public void setArguments(String[] arguments)
arguments
- The arguments to set.@Deprecated public Hashtable<String,org.pentaho.di.core.Counter> getCounters()
@Deprecated public void setCounters(Hashtable<String,org.pentaho.di.core.Counter> counters)
counters
- The counters to set.public List<TransDependency> getDependencies()
public void setDependencies(List<TransDependency> dependencies)
dependencies
- The dependency list to set.public org.pentaho.di.core.database.DatabaseMeta getMaxDateConnection()
public void setMaxDateConnection(org.pentaho.di.core.database.DatabaseMeta maxDateConnection)
maxDateConnection
- the database meta-data to setgetMaxDateConnection()
public double getMaxDateDifference()
public void setMaxDateDifference(double maxDateDifference)
maxDateDifference
- The date difference to set.getMaxDateDifference()
public String getMaxDateField()
getMaxDateConnection()
public void setMaxDateField(String maxDateField)
maxDateField
- The date field to set.getMaxDateField()
public double getMaxDateOffset()
setMaxDateOffset(double)
public void setMaxDateOffset(double maxDateOffset)
maxDateOffset
- The maxDateOffset to set.public String getMaxDateTable()
getMaxDateConnection()
public void setMaxDateTable(String maxDateTable)
maxDateTable
- The maxDateTable to set.getMaxDateTable()
public int getSizeRowset()
public void setSizeRowset(int sizeRowset)
sizeRowset
- The sizeRowset to set.public org.pentaho.di.core.DBCache getDbCache()
public void setDbCache(org.pentaho.di.core.DBCache dbCache)
dbCache
- the database cache object to setpublic String getTransversion()
public void setTransversion(String n)
n
- The new version description of the transformationpublic void setTransstatus(int n)
n
- The new status description of the transformationpublic int getTransstatus()
public String toString()
public void cancelQueries() throws org.pentaho.di.core.exception.KettleDatabaseException
org.pentaho.di.core.exception.KettleDatabaseException
- if any errors occur during query cancellationpublic Map<String,String> getUsedArguments(String[] arguments)
arguments
- the values for the argumentspublic int getSleepTimeEmpty()
public int getSleepTimeFull()
public void setSleepTimeEmpty(int sleepTimeEmpty)
sleepTimeEmpty
- the number of nano-seconds to wait while the input buffer is empty.public void setSleepTimeFull(int sleepTimeFull)
sleepTimeFull
- the number of nano-seconds to wait while the input buffer is full.public boolean isDatabaseConnectionUsed(org.pentaho.di.core.database.DatabaseMeta databaseMeta)
databaseMeta
- The connection to checkpublic List<StringSearchResult> getStringList(boolean searchSteps, boolean searchDatabases, boolean searchNotes, boolean includePasswords)
searchSteps
- true if steps should be searched, false otherwisesearchDatabases
- true if databases should be searched, false otherwisesearchNotes
- true if notes should be searched, false otherwiseincludePasswords
- true if passwords should be searched, false otherwisepublic List<StringSearchResult> getStringList(boolean searchSteps, boolean searchDatabases, boolean searchNotes)
searchSteps
- true if steps should be searched, false otherwisesearchDatabases
- true if databases should be searched, false otherwisesearchNotes
- true if notes should be searched, false otherwisepublic List<String> getUsedVariables()
@Deprecated public org.pentaho.di.core.Result getPreviousResult()
@Deprecated public void setPreviousResult(org.pentaho.di.core.Result previousResult)
previousResult
- The previous Result to set.@Deprecated public List<org.pentaho.di.core.ResultFile> getResultFiles()
@Deprecated public void setResultFiles(List<org.pentaho.di.core.ResultFile> resultFiles)
resultFiles
- The list of ResultFiles to set.public List<PartitionSchema> getPartitionSchemas()
public void setPartitionSchemas(List<PartitionSchema> partitionSchemas)
partitionSchemas
- the list of PartitionSchemas to setpublic String[] getPartitionSchemasNames()
public boolean isFeedbackShown()
public void setFeedbackShown(boolean feedbackShown)
feedbackShown
- true if feedback should be shown, false otherwisepublic int getFeedbackSize()
public void setFeedbackSize(int feedbackSize)
feedbackSize
- the feedback size to setpublic boolean isUsingUniqueConnections()
public void setUsingUniqueConnections(boolean usingUniqueConnections)
usingUniqueConnections
- true if the transformation is using unique database connections, false otherwisepublic List<ClusterSchema> getClusterSchemas()
public void setClusterSchemas(List<ClusterSchema> clusterSchemas)
clusterSchemas
- the list of ClusterSchemas to setpublic String[] getClusterSchemaNames()
public PartitionSchema findPartitionSchema(String name)
name
- The name of the partition schema to look for.public ClusterSchema findClusterSchema(String name)
name
- The name of the clustering schema to look for.public void addOrReplacePartitionSchema(PartitionSchema partitionSchema)
partitionSchema
- The partition schema to be added.public void addOrReplaceClusterSchema(ClusterSchema clusterSchema)
clusterSchema
- The cluster schema to be added.public void saveSharedObjects() throws org.pentaho.di.core.exception.KettleException
saveSharedObjects
in interface EngineMetaInterface
org.pentaho.di.core.exception.KettleException
- the kettle exceptionEngineMetaInterface.saveSharedObjects()
,
SharedObjects.saveToFile()
public boolean isUsingThreadPriorityManagment()
public void setUsingThreadPriorityManagment(boolean usingThreadPriorityManagment)
usingThreadPriorityManagment
- true if the transformation is using thread priority management, false otherwisepublic void checkRowMixingStatically(StepMeta stepMeta, org.pentaho.di.core.ProgressMonitorListener monitor) throws org.pentaho.di.core.exception.KettleRowException
stepMeta
- the step to checkmonitor
- the monitororg.pentaho.di.core.exception.KettleRowException
- in case we detect a row mixing violationpublic void setInternalKettleVariables(org.pentaho.di.core.variables.VariableSpace var)
setInternalKettleVariables
in class AbstractMeta
var
- the new internal kettle variablespublic StepMeta findMappingInputStep(String stepname) throws org.pentaho.di.core.exception.KettleStepException
stepname
- the name to search fororg.pentaho.di.core.exception.KettleStepException
- if any errors occur during the searchpublic StepMeta findMappingOutputStep(String stepname) throws org.pentaho.di.core.exception.KettleStepException
stepname
- the name to search fororg.pentaho.di.core.exception.KettleStepException
- if any errors occur during the searchpublic List<ResourceReference> getResourceDependencies()
public String exportResources(org.pentaho.di.core.variables.VariableSpace space, Map<String,ResourceDefinition> definitions, ResourceNamingInterface resourceNamingInterface, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore) throws org.pentaho.di.core.exception.KettleException
exportResources
in interface ResourceExportInterface
space
- the variable space to usedefinitions
- resourceNamingInterface
- repository
- The repository to optionally load other resources from (to be converted to XML)metaStore
- the metaStore in which non-kettle metadata could reside.org.pentaho.di.core.exception.KettleException
- in case something goes wrong during the exportpublic SlaveStepCopyPartitionDistribution getSlaveStepCopyPartitionDistribution()
public void setSlaveStepCopyPartitionDistribution(SlaveStepCopyPartitionDistribution slaveStepCopyPartitionDistribution)
slaveStepCopyPartitionDistribution
- the slaveStepCopyPartitionDistribution to setpublic ClusterSchema findFirstUsedClusterSchema()
public boolean isSlaveTransformation()
public void setSlaveTransformation(boolean slaveTransformation)
slaveTransformation
- true if the transformation is a slave transformation, false otherwisepublic boolean isCapturingStepPerformanceSnapShots()
public void setCapturingStepPerformanceSnapShots(boolean capturingStepPerformanceSnapShots)
capturingStepPerformanceSnapShots
- true if the transformation is capturing step performance snapshots, false otherwisepublic long getStepPerformanceCapturingDelay()
public void setStepPerformanceCapturingDelay(long stepPerformanceCapturingDelay)
stepPerformanceCapturingDelay
- the stepPerformanceCapturingDelay to setpublic String getStepPerformanceCapturingSizeLimit()
public void setStepPerformanceCapturingSizeLimit(String stepPerformanceCapturingSizeLimit)
stepPerformanceCapturingSizeLimit
- the step performance capturing size limit to setpublic void clearCaches()
public org.pentaho.di.repository.RepositoryObjectType getRepositoryElementType()
getRepositoryElementType
in interface org.pentaho.di.repository.RepositoryElementInterface
RepositoryElementInterface.getRepositoryElementType()
public org.pentaho.di.core.logging.LogChannelInterface getLogChannel()
public String getLogChannelId()
getLogChannelId
in interface org.pentaho.di.core.logging.LoggingObjectInterface
LoggingObjectInterface.getLogChannelId()
public org.pentaho.di.core.logging.LoggingObjectType getObjectType()
getObjectType
in interface org.pentaho.di.core.logging.LoggingObjectInterface
LoggingObjectInterface.getObjectType()
public TransLogTable getTransLogTable()
public void setTransLogTable(TransLogTable transLogTable)
the
- log table to setpublic PerformanceLogTable getPerformanceLogTable()
public void setPerformanceLogTable(PerformanceLogTable performanceLogTable)
performanceLogTable
- the performance log table to setpublic StepLogTable getStepLogTable()
public void setStepLogTable(StepLogTable stepLogTable)
stepLogTable
- the step log table to setpublic List<LogTableInterface> getLogTables()
public TransMeta.TransformationType getTransformationType()
public void setTransformationType(TransMeta.TransformationType transformationType)
transformationType
- the transformationType to setpublic void writeXML(String filename) throws org.pentaho.di.core.exception.KettleXMLException
filename
- The filename to save toorg.pentaho.di.core.exception.KettleXMLException
- in case something goes wrong.public boolean hasRepositoryReferences()
public void lookupRepositoryReferences(Repository repository) throws org.pentaho.di.core.exception.KettleException
repository
- the repository to reference.org.pentaho.di.core.exception.KettleException
- the kettle exceptionpublic MetricsLogTable getMetricsLogTable()
public void setMetricsLogTable(MetricsLogTable metricsLogTable)
metricsLogTable
- the metricsLogTable to setpublic boolean isGatheringMetrics()
isGatheringMetrics
in interface org.pentaho.di.core.logging.LoggingObjectInterface
public void setGatheringMetrics(boolean gatheringMetrics)
setGatheringMetrics
in interface org.pentaho.di.core.logging.LoggingObjectInterface
public boolean isForcingSeparateLogging()
isForcingSeparateLogging
in interface org.pentaho.di.core.logging.LoggingObjectInterface
public void setForcingSeparateLogging(boolean forcingSeparateLogging)
setForcingSeparateLogging
in interface org.pentaho.di.core.logging.LoggingObjectInterface
public void saveMetaStoreObjects(Repository repository, org.pentaho.metastore.api.IMetaStore metaStore) throws org.pentaho.metastore.api.exceptions.MetaStoreException
metaStore
- The store to save toorg.pentaho.metastore.api.exceptions.MetaStoreException
- in case there is an error.public void addStepChangeListener(StepMetaChangeListenerInterface listener)
public void addStepChangeListener(int p, StepMetaChangeListenerInterface list)
public void removeStepChangeListener(StepMetaChangeListenerInterface list)
public boolean containsStepMeta(StepMeta stepMeta)
public List<MissingTrans> getMissingTrans()
public void addMissingTrans(MissingTrans trans)
public void removeMissingTrans(MissingTrans trans)
public boolean hasMissingPlugins()
hasMissingPlugins
in class AbstractMeta