public class TransMeta extends AbstractMeta implements XMLInterface, Comparator<TransMeta>, Comparable<TransMeta>, Cloneable, ResourceExportInterface, RepositoryElementInterface, 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 |
---|---|
protected String[] |
arguments
Deprecated.
Moved to Trans
|
static int |
BORDER_INDENT |
protected boolean |
capturingStepPerformanceSnapShots
Whether the transformation is capturing step performance snap shots.
|
protected boolean |
changed_hops
Indicators for changes in steps, databases, hops, and notes.
|
protected boolean |
changed_steps
Indicators for changes in steps, databases, hops, and notes.
|
protected List<ClusterSchema> |
clusterSchemas
The list of cluster schemas associated with the transformation.
|
protected Hashtable<String,Counter> |
counters
Deprecated.
Moved to Trans
|
protected DBCache |
dbCache
The database cache.
|
protected List<TransDependency> |
dependencies
The list of dependencies associated with the transformation.
|
static String[] |
desc_type_undo
A list of localized strings corresponding to string descriptions of the undo/redo actions.
|
protected boolean |
feedbackShown
Whether the feedback is shown.
|
protected int |
feedbackSize
The feedback size.
|
protected List<TransHopMeta> |
hops
The list of hops associated with the transformation.
|
protected byte[] |
keyForSessionKey |
protected LogChannelInterface |
log
The log channel interface.
|
protected Map<String,Boolean> |
loopCache
The loop cache.
|
protected DatabaseMeta |
maxDateConnection
The meta-data for the database connection associated with "max date" auditing information.
|
protected double |
maxDateDifference
The maximum date difference used for "max date" auditing and limiting job sizes.
|
protected String |
maxDateField
The field associated with "max date" auditing information.
|
protected double |
maxDateOffset
The amount by which to increase the "max date" value.
|
protected String |
maxDateTable
The table name associated with "max date" auditing information.
|
protected MetricsLogTable |
metricsLogTable
The metricslogging table associated with the transformation.
|
protected PerformanceLogTable |
performanceLogTable
The performance logging table associated with the transformation.
|
protected Result |
previousResult
The previous result.
|
protected Map<String,List<StepMeta>> |
previousStepCache
The previous step cache
|
static RepositoryObjectType |
REPOSITORY_ELEMENT_TYPE
A constant specifying the repository element type as a Transformation.
|
protected List<ResultFile> |
resultFiles
Deprecated.
|
protected List<RowMetaAndData> |
resultRows
Deprecated.
|
protected int |
sizeRowset
The size of the current rowset.
|
protected SlaveStepCopyPartitionDistribution |
slaveStepCopyPartitionDistribution
The slave-step-copy/partition distribution.
|
protected boolean |
slaveTransformation
Just a flag indicating that this is a slave transformation - internal use only, no GUI option.
|
protected int |
sleepTimeEmpty
The time (in nanoseconds) to wait when the input buffer is empty.
|
protected int |
sleepTimeFull
The time (in nanoseconds) to wait when the input buffer is full.
|
protected List<StepMetaChangeListenerInterface> |
stepChangeListeners
The list of StepChangeListeners
|
protected StepLogTable |
stepLogTable
The step logging table associated with the transformation.
|
protected long |
stepPerformanceCapturingDelay
The step performance capturing delay.
|
protected String |
stepPerformanceCapturingSizeLimit
The step performance capturing size limit.
|
protected List<StepMeta> |
steps
The list of steps associated with the transformation.
|
protected Map<String,RowMetaInterface> |
stepsFieldsCache
The steps fields cache.
|
static String |
STRING_TRANSMETA
A constant used by the logging operations to indicate any logged messages are related to transformation meta-data.
|
protected int |
trans_status
The status of the transformation.
|
protected String |
trans_version
The version string for the transformation.
|
protected TransMeta.TransformationType |
transformationType
The transformation type.
|
protected TransLogTable |
transLogTable
The transformation logging table associated with the transformation.
|
protected boolean |
usingThreadPriorityManagment
Flag to indicate thread management usage.
|
protected boolean |
usingUniqueConnections
Whether the transformation is using unique connections.
|
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.
|
protected static String |
XML_TAG_DEPENDENCIES
A constant specifying the tag value for the XML node of the transformation dependencies.
|
protected static String |
XML_TAG_INFO
A constant specifying the tag value for the XML node of the transformation information.
|
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.
|
attributesMap, changedDatabases, changedFlag, changedNotes, channelLogTable, containerObjectId, contentChangedListeners, createdDate, createdUser, currentDirectoryChangedListeners, databases, description, directory, embeddedMetaStore, embeddedMetastoreProviderKey, extendedDescription, filename, filenameChangedListeners, logLevel, max_undo, metaStore, metastoreLocatorOsgi, modifiedDate, modifiedUser, name, nameChangedListeners, namedClusterEmbedManager, namedClusterServiceOsgi, namedParams, notes, objectId, objectRevision, privateDatabases, repository, runOptions, sharedObjects, sharedObjectsFile, slaveServers, TYPE_UNDO_CHANGE, TYPE_UNDO_DELETE, TYPE_UNDO_NEW, TYPE_UNDO_POSITION, undo, undo_position, variables
Constructor and Description |
---|
TransMeta()
Builds a new empty transformation.
|
TransMeta(InputStream xmlStream,
Repository rep,
boolean setInternalVariables,
VariableSpace parentVariableSpace,
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,
VariableSpace parentVariableSpace,
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,
VariableSpace parentVariableSpace)
Parses a file containing the XML that describes the transformation.
|
TransMeta(String fname,
Repository rep,
boolean setInternalVariables,
VariableSpace parentVariableSpace,
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,
VariableSpace parentVariableSpace)
Parses a file containing the XML that describes the transformation.
|
TransMeta(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,
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,
ProgressMonitorListener monitor)
Check a step to see if there are no multiple steps to read from.
|
void |
checkSteps(List<CheckResultInterface> remarks,
boolean only_selected,
ProgressMonitorListener monitor)
Deprecated.
|
void |
checkSteps(List<CheckResultInterface> remarks,
boolean only_selected,
ProgressMonitorListener monitor,
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(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.
|
List<TransHopMeta> |
findAllTransHopFrom(StepMeta fromstep) |
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.
|
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.
|
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.
|
protected List<SharedObjectInterface> |
getAllSharedObjects() |
String |
getAlternativeStepname(String stepname)
Proposes an alternative stepname when the original already exists.
|
String[] |
getArguments()
Deprecated.
moved to Trans
|
int |
getCacheVersion() |
String[] |
getClusterSchemaNames()
Gets the cluster schema names.
|
List<ClusterSchema> |
getClusterSchemas()
Gets a list of the cluster schemas used by the transformation.
|
Hashtable<String,Counter> |
getCounters()
Deprecated.
moved to Trans
|
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() |
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.
|
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.
|
Point |
getMaximum()
Gets the maximum size of the canvas by calculating the maximum location of a step.
|
MetricsLogTable |
getMetricsLogTable() |
Point |
getMinimum()
Gets the minimum point on the canvas of a transformation.
|
List<MissingTrans> |
getMissingTrans() |
NamedClusterEmbedManager |
getNamedClusterEmbedManager() |
String[] |
getNextStepNames(StepMeta stepMeta)
Retrieve an array of succeeding step names for a certain originating step.
|
StepMeta[] |
getNextSteps(StepMeta stepMeta)
Deprecated.
use findNextSteps instead
|
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.
|
RowMetaInterface |
getPrevInfoFields(StepMeta stepMeta)
Find the informational fields coming from an informational step into the step specified.
|
RowMetaInterface |
getPrevInfoFields(String stepname)
Find the informational fields coming from an informational step into the step specified.
|
Result |
getPreviousResult()
Deprecated.
this was moved to Trans to keep the metadata stateless
|
RowMetaInterface |
getPrevStepFields(StepMeta stepMeta)
Find the fields that are entering a certain step.
|
RowMetaInterface |
getPrevStepFields(StepMeta stepMeta,
ProgressMonitorListener monitor)
Find the fields that are entering a certain step.
|
RowMetaInterface |
getPrevStepFields(StepMeta stepMeta,
String stepName,
ProgressMonitorListener monitor) |
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.
|
RepositoryObjectType |
getRepositoryElementType()
Gets the repository element type.
|
List<ResourceReference> |
getResourceDependencies()
Gets a list of the resource dependencies.
|
List<ResultFile> |
getResultFiles()
Deprecated.
this was moved to Trans to keep the metadata stateless
|
List<RowMetaAndData> |
getResultRows()
Deprecated.
Moved to Trans to make this class stateless
|
Point[] |
getSelectedNoteLocations()
Get an array of all the selected note locations.
|
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<SQLStatement> |
getSQLStatements()
Builds a list of all the SQL statements that this transformation needs in order to work properly.
|
List<SQLStatement> |
getSQLStatements(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.
|
RowMetaInterface |
getStepFields(StepMeta stepMeta)
Returns the fields that are emitted by a certain step.
|
RowMetaInterface |
getStepFields(StepMeta[] stepMeta)
Gets the fields for each of the specified steps and merges them into a single set
|
RowMetaInterface |
getStepFields(StepMeta stepMeta,
ProgressMonitorListener monitor)
Returns the fields that are emitted by a certain step.
|
RowMetaInterface |
getStepFields(StepMeta stepMeta,
StepMeta targetStep,
ProgressMonitorListener monitor)
Returns the fields that are emitted by a certain step.
|
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.
|
RowMetaInterface |
getThisStepFields(StepMeta stepMeta,
StepMeta nextStep,
RowMetaInterface row)
Returns the fields that are emitted by a step.
|
RowMetaInterface |
getThisStepFields(StepMeta stepMeta,
StepMeta nextStep,
RowMetaInterface row,
ProgressMonitorListener monitor)
Returns the fields that are emitted by a step.
|
RowMetaInterface |
getThisStepFields(String stepname,
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<TransHopMeta> |
getTransHops()
Get a list of defined hops in this transformation.
|
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
|
String |
getXML(boolean includeSteps,
boolean includeDatabase,
boolean includeSlaves,
boolean includeClusters,
boolean includePartitions,
boolean includeNamedParameters,
boolean includeLog,
boolean includeDependencies,
boolean includeNotePads,
boolean includeAttributeGroups)
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 |
hasLoop(StepMeta stepMeta,
StepMeta lookup)
Checks for loop.
|
boolean |
hasLoop(StepMeta stepMeta,
StepMeta lookup,
boolean info)
Deprecated.
|
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 |
isAnySelectedStepUsedInTransHops()
Checks if any selected step has been used in a hop or not.
|
boolean |
isCapturingStepPerformanceSnapShots()
Checks whether the transformation is capturing step performance snapshots.
|
boolean |
isDatabaseConnectionUsed(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.
|
boolean |
loadSharedObject(SharedObjectInterface object) |
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,
VariableSpace parentVariableSpace)
Parses an XML DOM (starting at the specified Node) that describes the transformation.
|
void |
loadXML(Node transnode,
Repository rep,
boolean setInternalVariables,
VariableSpace parentVariableSpace,
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,
VariableSpace parentVariableSpace,
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,
VariableSpace parentVariableSpace,
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.
|
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 |
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,Counter> counters)
Deprecated.
moved to Trans
|
void |
setDbCache(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) |
protected void |
setInternalFilenameKettleVariables(VariableSpace var)
Sets the internal filename kettle variables.
|
void |
setInternalKettleVariables(VariableSpace var)
Sets the internal kettle variables.
|
protected void |
setInternalNameKettleVariable(VariableSpace var)
Sets the internal name kettle variable.
|
void |
setKey(byte[] key) |
void |
setMaxDateConnection(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(Result previousResult)
Deprecated.
this was moved to Trans to keep the metadata stateless
|
void |
setPrivateKey(boolean privateKey) |
void |
setResultFiles(List<ResultFile> resultFiles)
Deprecated.
this was moved to Trans to keep the metadata stateless
|
void |
setResultRows(List<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, addCurrentDirectoryChangedListener, addDatabase, addDatabase, addDatabase, addFilenameChangedListener, addNameChangedListener, addNote, addNote, addObserver, addOrReplaceDatabase, addOrReplaceSlaveServer, addParameterDefinition, addUndo, canSave, clearChangedDatabases, clearNameChangedListeners, clearParameters, clearUndo, compare, copyParametersFrom, copyVariablesFrom, deleteObserver, disposeEmbeddedMetastoreProvider, environmentSubstitute, environmentSubstitute, eraseParameters, fieldSubstitute, findDatabase, findSlaveServer, fireContentChangedListeners, fireContentChangedListeners, fireCurrentDirectoryChanged, fireFilenameChangedListeners, fireNameChangedListeners, getAttribute, getAttributes, getAttributesMap, getBooleanValueOfVariable, getChannelLogTable, getContainerObjectId, getContentChangedListeners, getCreatedDate, getCreatedUser, getDatabase, getDatabaseNames, getDatabases, getDescription, getEmbeddedMetaStore, getEmbeddedMetastoreProviderKey, getExtendedDescription, getFilename, getLogLevel, getMaxUndo, getMetaStore, getMetastoreLocatorOsgi, getModifiedDate, getModifiedUser, getName, getNamedClusterServiceOsgi, 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, getVersioningEnabled, hashCode, haveConnectionsChanged, haveNotesChanged, importFromMetaStore, indexOfDatabase, indexOfNote, initializeVariablesFrom, injectVariables, isAlwaysShowRunOptions, isClearingLog, isSafeModeEnabled, isShowDialog, listParameters, listVariables, lowerNote, mergeParametersWith, nameFromFilename, nextUndo, notifyObservers, nrDatabases, nrNotes, previousUndo, raiseNote, readSharedObjects, removeContentChangedListener, removeCurrentDirectoryChangedListener, removeDatabase, removeFilenameChangedListener, removeNameChangedListener, removeNote, saveMetaStoreObjects, saveSharedObjects, setAlwaysShowRunOptions, setAttribute, setAttributes, setAttributesMap, setCarteObjectId, setChanged, setChanged, setChannelLogTable, setClearingLog, setCreatedDate, setCreatedUser, setDatabases, setDescription, setEmbeddedMetastoreProviderKey, setExtendedDescription, setFilename, setInternalKettleVariables, setLogLevel, setMaxUndo, setMetaStore, setMetastoreLocatorOsgi, setModifiedDate, setModifiedUser, setName, setNamedClusterServiceOsgi, setObjectId, setObjectRevision, setParameterValue, setParentVariableSpace, setPrivateDatabases, setRepository, setRepositoryDirectory, setSafeModeEnabled, setSharedObjects, setSharedObjectsFile, setShowDialog, setSlaveServers, setVariable, setVersioningEnabled, shareVariablesWith, shouldOverwrite, viewNextUndo, viewPreviousUndo, viewThisUndo
finalize, getClass, notify, notifyAll, wait, wait, wait
comparing, comparing, comparingDouble, comparingInt, comparingLong, naturalOrder, nullsFirst, nullsLast, reversed, reverseOrder, thenComparing, thenComparing, thenComparing, thenComparingDouble, thenComparingInt, thenComparingLong
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 RepositoryObjectType REPOSITORY_ELEMENT_TYPE
public static final int BORDER_INDENT
protected List<TransHopMeta> hops
protected List<TransDependency> dependencies
protected List<ClusterSchema> clusterSchemas
protected String trans_version
protected int trans_status
protected TransLogTable transLogTable
protected PerformanceLogTable performanceLogTable
protected StepLogTable stepLogTable
protected MetricsLogTable metricsLogTable
protected int sizeRowset
protected DatabaseMeta maxDateConnection
protected String maxDateTable
protected String maxDateField
protected double maxDateOffset
protected double maxDateDifference
@Deprecated protected String[] arguments
@Deprecated protected Hashtable<String,Counter> counters
protected boolean changed_steps
protected boolean changed_hops
protected DBCache dbCache
protected int sleepTimeEmpty
protected int sleepTimeFull
protected Result previousResult
@Deprecated protected List<RowMetaAndData> resultRows
@Deprecated protected List<ResultFile> resultFiles
protected boolean usingUniqueConnections
protected boolean feedbackShown
protected int feedbackSize
protected boolean usingThreadPriorityManagment
protected SlaveStepCopyPartitionDistribution slaveStepCopyPartitionDistribution
protected boolean slaveTransformation
protected boolean capturingStepPerformanceSnapShots
protected long stepPerformanceCapturingDelay
protected String stepPerformanceCapturingSizeLimit
protected Map<String,RowMetaInterface> stepsFieldsCache
protected LogChannelInterface log
protected List<StepMetaChangeListenerInterface> stepChangeListeners
protected byte[] keyForSessionKey
protected TransMeta.TransformationType transformationType
public static final String[] desc_type_undo
protected static final String XML_TAG_INFO
public static final String XML_TAG_ORDER
public static final String XML_TAG_NOTEPADS
public static final String XML_TAG_PARAMETERS
protected static final String XML_TAG_DEPENDENCIES
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(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 KettleXMLException, KettleMissingPluginsException
fname
- The filenameKettleXMLException
- if any errors occur during parsing of the specified fileKettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public TransMeta(String fname, VariableSpace parentVariableSpace) throws KettleXMLException, KettleMissingPluginsException
fname
- The filenameparentVariableSpace
- the parent variable spaceKettleXMLException
- if any errors occur during parsing of the specified fileKettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public TransMeta(String fname, boolean setInternalVariables) throws KettleXMLException, KettleMissingPluginsException
fname
- The filenamesetInternalVariables
- true if you want to set the internal variables based on this transformation informationKettleXMLException
- if any errors occur during parsing of the specified fileKettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public TransMeta(String fname, Repository rep) throws KettleXMLException, KettleMissingPluginsException
fname
- The filenamerep
- The repository to load the default set of connections from, null if no repository is availableKettleXMLException
- if any errors occur during parsing of the specified fileKettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public TransMeta(String fname, Repository rep, boolean setInternalVariables) throws KettleXMLException, 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 informationKettleXMLException
- if any errors occur during parsing of the specified fileKettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public TransMeta(String fname, Repository rep, boolean setInternalVariables, VariableSpace parentVariableSpace) throws KettleXMLException, 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 constructionKettleXMLException
- if any errors occur during parsing of the specified fileKettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public TransMeta(String fname, Repository rep, boolean setInternalVariables, VariableSpace parentVariableSpace, OverwritePrompter prompter) throws KettleXMLException, 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 noneKettleXMLException
- if any errors occur during parsing of the specified fileKettleMissingPluginsException
- 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, VariableSpace parentVariableSpace, OverwritePrompter prompter) throws KettleXMLException, 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 noneKettleXMLException
- if any errors occur during parsing of the specified fileKettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public TransMeta(InputStream xmlStream, Repository rep, boolean setInternalVariables, VariableSpace parentVariableSpace, OverwritePrompter prompter) throws KettleXMLException, 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 oneKettleXMLException
- if any errors occur during parsing of the specified streamKettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public TransMeta(Node transnode, Repository rep) throws KettleXMLException, KettleMissingPluginsException
transnode
- The XML node to load fromrep
- the repository to reference.KettleXMLException
- if any errors occur during parsing of the specified fileKettleMissingPluginsException
- 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 List<TransHopMeta> getTransHops()
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 List<TransHopMeta> findAllTransHopFrom(StepMeta fromstep)
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 RowMetaInterface getPrevInfoFields(String stepname) throws KettleStepException
stepname
- The name of the stepKettleStepException
- the kettle step exceptionpublic RowMetaInterface getPrevInfoFields(StepMeta stepMeta) throws KettleStepException
stepMeta
- The receiving stepKettleStepException
- the kettle step exception@Deprecated public int findNrNextSteps(StepMeta stepMeta)
getNextSteps(StepMeta)
stepMeta
- The originating step@Deprecated public StepMeta findNextStep(StepMeta stepMeta, int nr)
getNextSteps(StepMeta)
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 RowMetaInterface getStepFields(String stepname) throws KettleStepException
stepname
- The stepname of the step to be queried.KettleStepException
- the kettle step exceptionpublic RowMetaInterface getStepFields(StepMeta stepMeta) throws KettleStepException
stepMeta
- The step to be queried.KettleStepException
- the kettle step exceptionpublic RowMetaInterface getStepFields(StepMeta[] stepMeta) throws KettleStepException
stepMeta
- the step metaKettleStepException
- the kettle step exceptionpublic RowMetaInterface getStepFields(StepMeta stepMeta, ProgressMonitorListener monitor) throws KettleStepException
stepMeta
- The step to be queried.monitor
- The progress monitor for progress dialog. (null if not used!)KettleStepException
- the kettle step exceptionpublic RowMetaInterface getStepFields(StepMeta stepMeta, StepMeta targetStep, ProgressMonitorListener monitor) throws KettleStepException
stepMeta
- The step to be queried.targetStep
- the target stepmonitor
- The progress monitor for progress dialog. (null if not used!)KettleStepException
- the kettle step exceptionpublic RowMetaInterface getPrevStepFields(String stepname) throws KettleStepException
stepname
- The name of the step queriedKettleStepException
- the kettle step exceptionpublic RowMetaInterface getPrevStepFields(StepMeta stepMeta) throws KettleStepException
stepMeta
- The step queriedKettleStepException
- the kettle step exceptionpublic RowMetaInterface getPrevStepFields(StepMeta stepMeta, ProgressMonitorListener monitor) throws KettleStepException
stepMeta
- The step queriedmonitor
- The progress monitor for progress dialog. (null if not used!)KettleStepException
- the kettle step exceptionpublic RowMetaInterface getPrevStepFields(StepMeta stepMeta, String stepName, ProgressMonitorListener monitor) throws KettleStepException
KettleStepException
public RowMetaInterface getThisStepFields(String stepname, RowMetaInterface row) throws 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.KettleStepException
- the kettle step exceptionpublic RowMetaInterface getThisStepFields(StepMeta stepMeta, StepMeta nextStep, RowMetaInterface row) throws 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.KettleStepException
- the kettle step exceptionpublic RowMetaInterface getThisStepFields(StepMeta stepMeta, StepMeta nextStep, RowMetaInterface row, ProgressMonitorListener monitor) throws 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 monitorKettleStepException
- 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 KettleException
slaveServer
- the slave serverKettleException
- 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 KettleException
getXML
in interface EngineMetaInterface
getXML
in interface XMLInterface
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 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 dataKettleException
- if any errors occur during generation of the XMLpublic String getXML(boolean includeSteps, boolean includeDatabase, boolean includeSlaves, boolean includeClusters, boolean includePartitions, boolean includeNamedParameters, boolean includeLog, boolean includeDependencies, boolean includeNotePads, boolean includeAttributeGroups) throws 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 dataincludeNamedParameters
- whether to include named parameters dataincludeLog
- whether to include log dataincludeDependencies
- whether to include dependencies dataincludeNotePads
- whether to include notepads dataincludeAttributeGroups
- whether to include attributes map dataKettleException
- if any errors occur during generation of the XMLpublic void loadXML(Node transnode, Repository rep, boolean setInternalVariables) throws KettleXMLException, 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 informationKettleXMLException
- if any errors occur during parsing of the specified fileKettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public void loadXML(Node transnode, Repository rep, boolean setInternalVariables, VariableSpace parentVariableSpace) throws KettleXMLException, 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 constructionKettleXMLException
- if any errors occur during parsing of the specified fileKettleMissingPluginsException
- in case missing plugins were found (details are in the exception in that case)public void loadXML(Node transnode, Repository rep, boolean setInternalVariables, VariableSpace parentVariableSpace, OverwritePrompter prompter) throws KettleXMLException, 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 noneKettleXMLException
- if any errors occur during parsing of the specified fileKettleMissingPluginsException
- 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, VariableSpace parentVariableSpace, OverwritePrompter prompter) throws KettleXMLException, 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 noneKettleXMLException
- if any errors occur during parsing of the specified fileKettleMissingPluginsException
- 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, VariableSpace parentVariableSpace, OverwritePrompter prompter) throws KettleXMLException, 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 noneKettleXMLException
- if any errors occur during parsing of the specified fileKettleMissingPluginsException
- 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 boolean loadSharedObject(SharedObjectInterface object)
loadSharedObject
in class AbstractMeta
public 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 boolean isAnySelectedStepUsedInTransHops()
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 looking@Deprecated public boolean hasLoop(StepMeta stepMeta, StepMeta lookup, boolean info)
hasLoop(StepMeta, StepMeta)
}public boolean hasLoop(StepMeta stepMeta, StepMeta lookup)
stepMeta
- the stepmetalookup
- the lookuppublic void selectAll()
public void unselectAll()
public Point[] getSelectedStepLocations()
public Point[] getSelectedNoteLocations()
public List<StepMeta> getSelectedSteps()
public String[] getSelectedStepNames()
public int[] getStepIndexes(List<StepMeta> steps)
steps
- An array of stepspublic Point getMaximum()
public 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, ProgressMonitorListener monitor) throws KettleStepException
impact
- An ArrayList of DatabaseImpact objects.monitor
- a progress monitor listener to be updated as the transformation is analyzedKettleStepException
- if any errors occur during analysispublic String getAlternativeStepname(String stepname)
stepname
- The stepname to find an alternative forpublic List<SQLStatement> getSQLStatements() throws KettleStepException
KettleStepException
- if any errors occur during SQL statement generationpublic List<SQLStatement> getSQLStatements(ProgressMonitorListener monitor) throws KettleStepException
monitor
- a progress monitor listener to be updated as the SQL statements are generatedKettleStepException
- if any errors occur during SQL statement generationpublic String getSQLStatementsString() throws KettleStepException
KettleStepException
- if any errors occur during SQL statement generation@Deprecated public void checkSteps(List<CheckResultInterface> remarks, boolean only_selected, 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<CheckResultInterface> remarks, boolean only_selected, ProgressMonitorListener monitor, 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<RowMetaAndData> getResultRows()
@Deprecated public void setResultRows(List<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,Counter> getCounters()
@Deprecated public void setCounters(Hashtable<String,Counter> counters)
counters
- The counters to set.public List<TransDependency> getDependencies()
public void setDependencies(List<TransDependency> dependencies)
dependencies
- The dependency list to set.public DatabaseMeta getMaxDateConnection()
public void setMaxDateConnection(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 DBCache getDbCache()
public void setDbCache(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 KettleDatabaseException
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(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 Result getPreviousResult()
@Deprecated public void setPreviousResult(Result previousResult)
previousResult
- The previous Result to set.@Deprecated public List<ResultFile> getResultFiles()
@Deprecated public void setResultFiles(List<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.protected List<SharedObjectInterface> getAllSharedObjects()
getAllSharedObjects
in class AbstractMeta
public boolean isUsingThreadPriorityManagment()
public void setUsingThreadPriorityManagment(boolean usingThreadPriorityManagment)
usingThreadPriorityManagment
- true if the transformation is using thread priority management, false otherwisepublic void checkRowMixingStatically(StepMeta stepMeta, ProgressMonitorListener monitor) throws KettleRowException
stepMeta
- the step to checkmonitor
- the monitorKettleRowException
- in case we detect a row mixing violationpublic void setInternalKettleVariables(VariableSpace var)
setInternalKettleVariables
in class AbstractMeta
var
- the new internal kettle variablesprotected void setInternalNameKettleVariable(VariableSpace var)
setInternalNameKettleVariable
in class AbstractMeta
var
- the new internal name kettle variableprotected void setInternalFilenameKettleVariables(VariableSpace var)
setInternalFilenameKettleVariables
in class AbstractMeta
var
- the new internal filename kettle variablespublic StepMeta findMappingInputStep(String stepname) throws KettleStepException
stepname
- the name to search forKettleStepException
- if any errors occur during the searchpublic StepMeta findMappingOutputStep(String stepname) throws KettleStepException
stepname
- the name to search forKettleStepException
- if any errors occur during the searchpublic List<ResourceReference> getResourceDependencies()
public String exportResources(VariableSpace space, Map<String,ResourceDefinition> definitions, ResourceNamingInterface resourceNamingInterface, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore) throws 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.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 RepositoryObjectType getRepositoryElementType()
getRepositoryElementType
in interface RepositoryElementInterface
RepositoryElementInterface.getRepositoryElementType()
public LogChannelInterface getLogChannel()
public String getLogChannelId()
getLogChannelId
in interface LoggingObjectInterface
LoggingObjectInterface.getLogChannelId()
public LoggingObjectType getObjectType()
getObjectType
in interface LoggingObjectInterface
LoggingObjectInterface.getObjectType()
public TransLogTable getTransLogTable()
public void setTransLogTable(TransLogTable 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 KettleXMLException
filename
- The filename to save toKettleXMLException
- in case something goes wrong.public boolean hasRepositoryReferences()
public void lookupRepositoryReferences(Repository repository) throws KettleException
repository
- the repository to reference.KettleException
- the kettle exceptionpublic MetricsLogTable getMetricsLogTable()
public void setMetricsLogTable(MetricsLogTable metricsLogTable)
metricsLogTable
- the metricsLogTable to setpublic boolean isGatheringMetrics()
isGatheringMetrics
in interface LoggingObjectInterface
public void setGatheringMetrics(boolean gatheringMetrics)
setGatheringMetrics
in interface LoggingObjectInterface
public boolean isForcingSeparateLogging()
isForcingSeparateLogging
in interface LoggingObjectInterface
public void setForcingSeparateLogging(boolean forcingSeparateLogging)
setForcingSeparateLogging
in interface LoggingObjectInterface
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
public NamedClusterEmbedManager getNamedClusterEmbedManager()
getNamedClusterEmbedManager
in class AbstractMeta
public int getCacheVersion() throws KettleException
KettleException
Copyright © 2018 Hitachi Vantara. All rights reserved.