@Test public void testCloneWithParam() throws Exception { TransMeta transMeta = new TransMeta( "transFile", "myTrans" ); transMeta.addParameterDefinition( "key", "defValue", "description" ); Object clone = transMeta.realClone( true ); assertNotNull( clone ); }
public Object realClone( boolean doClear ) { try { TransMeta transMeta = (TransMeta) super.clone(); if ( doClear ) { transMeta.clear(); } else { transMeta.databases = new ArrayList<>(); transMeta.steps = new ArrayList<>(); transMeta.hops = new ArrayList<>(); transMeta.notes = new ArrayList<>(); transMeta.dependencies = new ArrayList<>(); transMeta.partitionSchemas = new ArrayList<>(); transMeta.slaveServers = new ArrayList<>(); transMeta.clusterSchemas = new ArrayList<>(); transMeta.namedParams = new NamedParamsDefault(); transMeta.stepChangeListeners = new ArrayList<>(); } for ( DatabaseMeta db : databases ) { transMeta.addDatabase( (DatabaseMeta) db.clone() ); } for ( StepMeta step : steps ) { transMeta.addStep( (StepMeta) step.clone() ); } for ( StepMeta step : transMeta.getSteps() ) { final StepMetaInterface stepMetaInterface = step.getStepMetaInterface(); if ( stepMetaInterface != null ) { final StepIOMetaInterface stepIOMeta = stepMetaInterface.getStepIOMeta(); if ( stepIOMeta != null ) { for ( StreamInterface stream : stepIOMeta.getInfoStreams() ) { String streamStepName = stream.getStepname(); if ( streamStepName != null ) { StepMeta streamStepMeta = transMeta.findStep( streamStepName ); stream.setStepMeta( streamStepMeta ); } } } } } for ( TransHopMeta hop : hops ) { transMeta.addTransHop( (TransHopMeta) hop.clone() ); } for ( NotePadMeta note : notes ) { transMeta.addNote( (NotePadMeta) note.clone() ); } for ( TransDependency dep : dependencies ) { transMeta.addDependency( (TransDependency) dep.clone() ); } for ( SlaveServer slave : slaveServers ) { transMeta.getSlaveServers().add( (SlaveServer) slave.clone() ); } for ( ClusterSchema schema : clusterSchemas ) { transMeta.getClusterSchemas().add( schema.clone() ); } for ( PartitionSchema schema : partitionSchemas ) { transMeta.getPartitionSchemas().add( (PartitionSchema) schema.clone() ); } for ( String key : listParameters() ) { transMeta.addParameterDefinition( key, getParameterDefault( key ), getParameterDescription( key ) ); } return transMeta; } catch ( Exception e ) { e.printStackTrace(); return null; } }
TransMeta extends AbstractMeta implements XMLInterface, Comparator<TransMeta>, Comparable<TransMeta>, Cloneable, ResourceExportInterface,
    RepositoryElementInterface, LoggingObjectInterface { public Object realClone( boolean doClear ) { try { TransMeta transMeta = (TransMeta) super.clone(); if ( doClear ) { transMeta.clear(); } else { transMeta.databases = new ArrayList<>(); transMeta.steps = new ArrayList<>(); transMeta.hops = new ArrayList<>(); transMeta.notes = new ArrayList<>(); transMeta.dependencies = new ArrayList<>(); transMeta.partitionSchemas = new ArrayList<>(); transMeta.slaveServers = new ArrayList<>(); transMeta.clusterSchemas = new ArrayList<>(); transMeta.namedParams = new NamedParamsDefault(); transMeta.stepChangeListeners = new ArrayList<>(); } for ( DatabaseMeta db : databases ) { transMeta.addDatabase( (DatabaseMeta) db.clone() ); } for ( StepMeta step : steps ) { transMeta.addStep( (StepMeta) step.clone() ); } for ( StepMeta step : transMeta.getSteps() ) { final StepMetaInterface stepMetaInterface = step.getStepMetaInterface(); if ( stepMetaInterface != null ) { final StepIOMetaInterface stepIOMeta = stepMetaInterface.getStepIOMeta(); if ( stepIOMeta != null ) { for ( StreamInterface stream : stepIOMeta.getInfoStreams() ) { String streamStepName = stream.getStepname(); if ( streamStepName != null ) { StepMeta streamStepMeta = transMeta.findStep( streamStepName ); stream.setStepMeta( streamStepMeta ); } } } } } for ( TransHopMeta hop : hops ) { transMeta.addTransHop( (TransHopMeta) hop.clone() ); } for ( NotePadMeta note : notes ) { transMeta.addNote( (NotePadMeta) note.clone() ); } for ( TransDependency dep : dependencies ) { transMeta.addDependency( (TransDependency) dep.clone() ); } for ( SlaveServer slave : slaveServers ) { transMeta.getSlaveServers().add( (SlaveServer) slave.clone() ); } for ( ClusterSchema schema : clusterSchemas ) { transMeta.getClusterSchemas().add( schema.clone() ); } for ( PartitionSchema schema : partitionSchemas ) { transMeta.getPartitionSchemas().add( (PartitionSchema) schema.clone() ); } for ( String key : listParameters() ) { transMeta.addParameterDefinition( key, getParameterDefault( key ), getParameterDescription( key ) ); } return transMeta; } catch ( Exception e ) { e.printStackTrace(); return null; } } }
TransMeta extends AbstractMeta implements XMLInterface, Comparator<TransMeta>, Comparable<TransMeta>, Cloneable, ResourceExportInterface,
    RepositoryElementInterface, LoggingObjectInterface { public Object realClone( boolean doClear ) { try { TransMeta transMeta = (TransMeta) super.clone(); if ( doClear ) { transMeta.clear(); } else { transMeta.databases = new ArrayList<>(); transMeta.steps = new ArrayList<>(); transMeta.hops = new ArrayList<>(); transMeta.notes = new ArrayList<>(); transMeta.dependencies = new ArrayList<>(); transMeta.partitionSchemas = new ArrayList<>(); transMeta.slaveServers = new ArrayList<>(); transMeta.clusterSchemas = new ArrayList<>(); transMeta.namedParams = new NamedParamsDefault(); transMeta.stepChangeListeners = new ArrayList<>(); } for ( DatabaseMeta db : databases ) { transMeta.addDatabase( (DatabaseMeta) db.clone() ); } for ( StepMeta step : steps ) { transMeta.addStep( (StepMeta) step.clone() ); } for ( StepMeta step : transMeta.getSteps() ) { final StepMetaInterface stepMetaInterface = step.getStepMetaInterface(); if ( stepMetaInterface != null ) { final StepIOMetaInterface stepIOMeta = stepMetaInterface.getStepIOMeta(); if ( stepIOMeta != null ) { for ( StreamInterface stream : stepIOMeta.getInfoStreams() ) { String streamStepName = stream.getStepname(); if ( streamStepName != null ) { StepMeta streamStepMeta = transMeta.findStep( streamStepName ); stream.setStepMeta( streamStepMeta ); } } } } } for ( TransHopMeta hop : hops ) { transMeta.addTransHop( (TransHopMeta) hop.clone() ); } for ( NotePadMeta note : notes ) { transMeta.addNote( (NotePadMeta) note.clone() ); } for ( TransDependency dep : dependencies ) { transMeta.addDependency( (TransDependency) dep.clone() ); } for ( SlaveServer slave : slaveServers ) { transMeta.getSlaveServers().add( (SlaveServer) slave.clone() ); } for ( ClusterSchema schema : clusterSchemas ) { transMeta.getClusterSchemas().add( schema.clone() ); } for ( PartitionSchema schema : partitionSchemas ) { transMeta.getPartitionSchemas().add( (PartitionSchema) schema.clone() ); } for ( String key : listParameters() ) { transMeta.addParameterDefinition( key, getParameterDefault( key ), getParameterDescription( key ) ); } return transMeta; } catch ( Exception e ) { e.printStackTrace(); return null; } } TransMeta();  TransMeta( VariableSpace parent );  TransMeta( String filename, String name ); @Deprecated  TransMeta( String filename, String name, String[] arguments );  TransMeta( String fname );  TransMeta( String fname, VariableSpace parentVariableSpace );  TransMeta( String fname, boolean setInternalVariables );  TransMeta( String fname, Repository rep );  TransMeta( String fname, Repository rep, boolean setInternalVariables );  TransMeta( String fname, Repository rep, boolean setInternalVariables, VariableSpace parentVariableSpace );  TransMeta( String fname, Repository rep, boolean setInternalVariables, VariableSpace parentVariableSpace,
      OverwritePrompter prompter );  TransMeta( String fname, IMetaStore metaStore, Repository rep, boolean setInternalVariables,
                    VariableSpace parentVariableSpace, OverwritePrompter prompter );  TransMeta( InputStream xmlStream, Repository rep, boolean setInternalVariables,
                    VariableSpace parentVariableSpace, OverwritePrompter prompter );  TransMeta( Node transnode, Repository rep ); }
TransMeta extends AbstractMeta implements XMLInterface, Comparator<TransMeta>, Comparable<TransMeta>, Cloneable, ResourceExportInterface,
    RepositoryElementInterface, LoggingObjectInterface { public Object realClone( boolean doClear ) { try { TransMeta transMeta = (TransMeta) super.clone(); if ( doClear ) { transMeta.clear(); } else { transMeta.databases = new ArrayList<>(); transMeta.steps = new ArrayList<>(); transMeta.hops = new ArrayList<>(); transMeta.notes = new ArrayList<>(); transMeta.dependencies = new ArrayList<>(); transMeta.partitionSchemas = new ArrayList<>(); transMeta.slaveServers = new ArrayList<>(); transMeta.clusterSchemas = new ArrayList<>(); transMeta.namedParams = new NamedParamsDefault(); transMeta.stepChangeListeners = new ArrayList<>(); } for ( DatabaseMeta db : databases ) { transMeta.addDatabase( (DatabaseMeta) db.clone() ); } for ( StepMeta step : steps ) { transMeta.addStep( (StepMeta) step.clone() ); } for ( StepMeta step : transMeta.getSteps() ) { final StepMetaInterface stepMetaInterface = step.getStepMetaInterface(); if ( stepMetaInterface != null ) { final StepIOMetaInterface stepIOMeta = stepMetaInterface.getStepIOMeta(); if ( stepIOMeta != null ) { for ( StreamInterface stream : stepIOMeta.getInfoStreams() ) { String streamStepName = stream.getStepname(); if ( streamStepName != null ) { StepMeta streamStepMeta = transMeta.findStep( streamStepName ); stream.setStepMeta( streamStepMeta ); } } } } } for ( TransHopMeta hop : hops ) { transMeta.addTransHop( (TransHopMeta) hop.clone() ); } for ( NotePadMeta note : notes ) { transMeta.addNote( (NotePadMeta) note.clone() ); } for ( TransDependency dep : dependencies ) { transMeta.addDependency( (TransDependency) dep.clone() ); } for ( SlaveServer slave : slaveServers ) { transMeta.getSlaveServers().add( (SlaveServer) slave.clone() ); } for ( ClusterSchema schema : clusterSchemas ) { transMeta.getClusterSchemas().add( schema.clone() ); } for ( PartitionSchema schema : partitionSchemas ) { transMeta.getPartitionSchemas().add( (PartitionSchema) schema.clone() ); } for ( String key : listParameters() ) { transMeta.addParameterDefinition( key, getParameterDefault( key ), getParameterDescription( key ) ); } return transMeta; } catch ( Exception e ) { e.printStackTrace(); return null; } } TransMeta();  TransMeta( VariableSpace parent );  TransMeta( String filename, String name ); @Deprecated  TransMeta( String filename, String name, String[] arguments );  TransMeta( String fname );  TransMeta( String fname, VariableSpace parentVariableSpace );  TransMeta( String fname, boolean setInternalVariables );  TransMeta( String fname, Repository rep );  TransMeta( String fname, Repository rep, boolean setInternalVariables );  TransMeta( String fname, Repository rep, boolean setInternalVariables, VariableSpace parentVariableSpace );  TransMeta( String fname, Repository rep, boolean setInternalVariables, VariableSpace parentVariableSpace,
      OverwritePrompter prompter );  TransMeta( String fname, IMetaStore metaStore, Repository rep, boolean setInternalVariables,
                    VariableSpace parentVariableSpace, OverwritePrompter prompter );  TransMeta( InputStream xmlStream, Repository rep, boolean setInternalVariables,
                    VariableSpace parentVariableSpace, OverwritePrompter prompter );  TransMeta( Node transnode, Repository rep ); @Override int compare( TransMeta t1, TransMeta t2 ); @Override int compareTo( TransMeta o ); @Override boolean equals( Object obj ); @Override Object clone(); Object realClone( boolean doClear ); @Override void clear(); void addStep( StepMeta stepMeta ); void addOrReplaceStep( StepMeta stepMeta ); void addTransHop( TransHopMeta hi ); void addDependency( TransDependency td ); void addStep( int p, StepMeta stepMeta ); void addTransHop( int p, TransHopMeta hi ); void addDependency( int p, TransDependency td ); List<StepMeta> getSteps(); StepMeta getStep( int i ); TransHopMeta getTransHop( int i ); TransDependency getDependency( int i ); void removeStep( int i ); void removeTransHop( int i ); void removeTransHop( TransHopMeta hop ); void removeDependency( int i ); void removeAllDependencies(); int nrSteps(); int nrTransHops(); int nrDependencies(); int nrStepChangeListeners(); void setStep( int i, StepMeta stepMeta ); void setTransHop( int i, TransHopMeta hi ); List<StepMeta> getUsedSteps(); StepMeta findStep( String name ); StepMeta findStep( String name, StepMeta exclude ); TransHopMeta findTransHop( String name ); TransHopMeta findTransHopFrom( StepMeta fromstep ); List<TransHopMeta> findAllTransHopFrom( StepMeta fromstep ); TransHopMeta findTransHop( TransHopMeta hi ); TransHopMeta findTransHop( StepMeta from, StepMeta to ); TransHopMeta findTransHop( StepMeta from, StepMeta to, boolean disabledToo ); TransHopMeta findTransHopTo( StepMeta tostep ); boolean isStepInformative( StepMeta this_step, StepMeta prev_step ); @Deprecated int findNrPrevSteps( String stepname ); @Deprecated int findNrPrevSteps( String stepname, boolean info ); int findNrPrevSteps( StepMeta stepMeta ); @Deprecated StepMeta findPrevStep( String stepname, int nr ); @Deprecated StepMeta findPrevStep( String stepname, int nr, boolean info ); StepMeta findPrevStep( StepMeta stepMeta, int nr ); @Deprecated int findNrPrevSteps( StepMeta stepMeta, boolean info ); @Deprecated StepMeta findPrevStep( StepMeta stepMeta, int nr, boolean info ); List<StepMeta> findPreviousSteps( StepMeta stepMeta ); List<StepMeta> findPreviousSteps( StepMeta stepMeta, boolean info ); StepMeta[] getInfoStep( StepMeta stepMeta ); int findNrInfoSteps( StepMeta stepMeta ); RowMetaInterface getPrevInfoFields( String stepname ); RowMetaInterface getPrevInfoFields( StepMeta stepMeta ); @Deprecated int findNrNextSteps( StepMeta stepMeta ); @Deprecated StepMeta findNextStep( StepMeta stepMeta, int nr ); StepMeta[] getPrevSteps( StepMeta stepMeta ); String[] getPrevStepNames( String stepname ); String[] getPrevStepNames( StepMeta stepMeta ); @Deprecated StepMeta[] getNextSteps( StepMeta stepMeta ); List<StepMeta> findNextSteps( StepMeta stepMeta ); String[] getNextStepNames( StepMeta stepMeta ); StepMeta getStep( int x, int y, int iconsize ); boolean partOfTransHop( StepMeta stepMeta ); RowMetaInterface getStepFields( String stepname ); RowMetaInterface getStepFields( StepMeta stepMeta ); RowMetaInterface getStepFields( StepMeta[] stepMeta ); RowMetaInterface getStepFields( StepMeta stepMeta, ProgressMonitorListener monitor ); RowMetaInterface getStepFields( StepMeta stepMeta, StepMeta targetStep, ProgressMonitorListener monitor ); RowMetaInterface getPrevStepFields( String stepname ); RowMetaInterface getPrevStepFields( StepMeta stepMeta ); RowMetaInterface getPrevStepFields( StepMeta stepMeta, ProgressMonitorListener monitor ); RowMetaInterface getThisStepFields( String stepname, RowMetaInterface row ); RowMetaInterface getThisStepFields( StepMeta stepMeta, StepMeta nextStep, RowMetaInterface row ); RowMetaInterface getThisStepFields( StepMeta stepMeta, StepMeta nextStep, RowMetaInterface row,
      ProgressMonitorListener monitor ); boolean isUsingPartitionSchema( PartitionSchema partitionSchema ); boolean isUsingAClusterSchema(); boolean isUsingClusterSchema( ClusterSchema clusterSchema ); boolean isUsingSlaveServer( SlaveServer slaveServer ); boolean isRepReference(); boolean isFileReference(); static boolean isRepReference( String exactFilename, String exactTransname ); static boolean isFileReference( String exactFilename, String exactTransname ); int indexOfTransHop( TransHopMeta hi ); int indexOfStep( StepMeta stepMeta ); @Override String getFileType(); @Override String[] getFilterNames(); @Override String[] getFilterExtensions(); @Override String getDefaultExtension(); @Override String getXML(); String getXML( boolean includeSteps, boolean includeDatabase, boolean includeSlaves, boolean includeClusters,
      boolean includePartitions ); void loadXML( Node transnode, Repository rep, boolean setInternalVariables ); void loadXML( Node transnode, Repository rep, boolean setInternalVariables, VariableSpace parentVariableSpace ); void loadXML( Node transnode, Repository rep, boolean setInternalVariables, VariableSpace parentVariableSpace,
      OverwritePrompter prompter ); void loadXML( Node transnode, String fname, Repository rep, boolean setInternalVariables,
                       VariableSpace parentVariableSpace, OverwritePrompter prompter ); void loadXML( Node transnode, String fname, IMetaStore metaStore, Repository rep, boolean setInternalVariables,
                       VariableSpace parentVariableSpace, OverwritePrompter prompter ); byte[] getKey(); void setKey( byte[] key ); boolean isPrivateKey(); void setPrivateKey( boolean privateKey ); @Override boolean loadSharedObject( SharedObjectInterface object ); List<StepMeta> getTransHopSteps( boolean all ); boolean isStepUsedInTransHops( StepMeta stepMeta ); boolean isAnySelectedStepUsedInTransHops(); @Override void clearChanged(); boolean haveStepsChanged(); boolean haveHopsChanged(); boolean havePartitionSchemasChanged(); boolean haveClusterSchemasChanged(); @Override boolean hasChanged(); boolean hasLoop( StepMeta stepMeta ); void selectAll(); void unselectAll(); Point[] getSelectedStepLocations(); Point[] getSelectedNoteLocations(); List<StepMeta> getSelectedSteps(); String[] getSelectedStepNames(); int[] getStepIndexes( List<StepMeta> steps ); Point getMaximum(); Point getMinimum(); String[] getStepNames(); StepMeta[] getStepsArray(); boolean findPrevious( StepMeta startStep, StepMeta stepToFind ); void sortSteps(); void sortHops(); Map<StepMeta, Map<StepMeta, Boolean>> sortStepsNatural(); void sortHopsNatural(); void analyseImpact( List<DatabaseImpact> impact, ProgressMonitorListener monitor ); String getAlternativeStepname( String stepname ); List<SQLStatement> getSQLStatements(); List<SQLStatement> getSQLStatements( ProgressMonitorListener monitor ); String getSQLStatementsString(); @Deprecated void checkSteps( List<CheckResultInterface> remarks, boolean only_selected, ProgressMonitorListener monitor ); void checkSteps( List<CheckResultInterface> remarks, boolean only_selected, ProgressMonitorListener monitor,
      VariableSpace space, Repository repository, IMetaStore metaStore ); @Deprecated List<RowMetaAndData> getResultRows(); @Deprecated void setResultRows( List<RowMetaAndData> resultRows ); String getPathAndName(); @Deprecated String[] getArguments(); @Deprecated void setArguments( String[] arguments ); @Deprecated Hashtable<String, Counter> getCounters(); @Deprecated void setCounters( Hashtable<String, Counter> counters ); List<TransDependency> getDependencies(); void setDependencies( List<TransDependency> dependencies ); DatabaseMeta getMaxDateConnection(); void setMaxDateConnection( DatabaseMeta maxDateConnection ); double getMaxDateDifference(); void setMaxDateDifference( double maxDateDifference ); String getMaxDateField(); void setMaxDateField( String maxDateField ); double getMaxDateOffset(); void setMaxDateOffset( double maxDateOffset ); String getMaxDateTable(); void setMaxDateTable( String maxDateTable ); int getSizeRowset(); void setSizeRowset( int sizeRowset ); DBCache getDbCache(); void setDbCache( DBCache dbCache ); String getTransversion(); void setTransversion( String n ); void setTransstatus( int n ); int getTransstatus(); @Override String toString(); void cancelQueries(); Map<String, String> getUsedArguments( String[] arguments ); int getSleepTimeEmpty(); int getSleepTimeFull(); void setSleepTimeEmpty( int sleepTimeEmpty ); void setSleepTimeFull( int sleepTimeFull ); boolean isDatabaseConnectionUsed( DatabaseMeta databaseMeta ); List<StringSearchResult> getStringList( boolean searchSteps, boolean searchDatabases, boolean searchNotes,
      boolean includePasswords ); List<StringSearchResult> getStringList( boolean searchSteps, boolean searchDatabases, boolean searchNotes ); List<String> getUsedVariables(); @Deprecated Result getPreviousResult(); @Deprecated void setPreviousResult( Result previousResult ); @Deprecated List<ResultFile> getResultFiles(); @Deprecated void setResultFiles( List<ResultFile> resultFiles ); List<PartitionSchema> getPartitionSchemas(); void setPartitionSchemas( List<PartitionSchema> partitionSchemas ); String[] getPartitionSchemasNames(); boolean isFeedbackShown(); void setFeedbackShown( boolean feedbackShown ); int getFeedbackSize(); void setFeedbackSize( int feedbackSize ); boolean isUsingUniqueConnections(); void setUsingUniqueConnections( boolean usingUniqueConnections ); List<ClusterSchema> getClusterSchemas(); void setClusterSchemas( List<ClusterSchema> clusterSchemas ); String[] getClusterSchemaNames(); PartitionSchema findPartitionSchema( String name ); ClusterSchema findClusterSchema( String name ); void addOrReplacePartitionSchema( PartitionSchema partitionSchema ); void addOrReplaceClusterSchema( ClusterSchema clusterSchema ); boolean isUsingThreadPriorityManagment(); void setUsingThreadPriorityManagment( boolean usingThreadPriorityManagment ); void checkRowMixingStatically( StepMeta stepMeta, ProgressMonitorListener monitor ); @Override void setInternalKettleVariables( VariableSpace var ); StepMeta findMappingInputStep( String stepname ); StepMeta findMappingOutputStep( String stepname ); List<ResourceReference> getResourceDependencies(); @Override String exportResources( VariableSpace space, Map<String, ResourceDefinition> definitions,
      ResourceNamingInterface resourceNamingInterface, Repository repository, IMetaStore metaStore ); SlaveStepCopyPartitionDistribution getSlaveStepCopyPartitionDistribution(); void setSlaveStepCopyPartitionDistribution(
      SlaveStepCopyPartitionDistribution slaveStepCopyPartitionDistribution ); ClusterSchema findFirstUsedClusterSchema(); boolean isSlaveTransformation(); void setSlaveTransformation( boolean slaveTransformation ); boolean isCapturingStepPerformanceSnapShots(); void setCapturingStepPerformanceSnapShots( boolean capturingStepPerformanceSnapShots ); long getStepPerformanceCapturingDelay(); void setStepPerformanceCapturingDelay( long stepPerformanceCapturingDelay ); String getStepPerformanceCapturingSizeLimit(); void setStepPerformanceCapturingSizeLimit( String stepPerformanceCapturingSizeLimit ); void clearCaches(); @Override RepositoryObjectType getRepositoryElementType(); LogChannelInterface getLogChannel(); @Override String getLogChannelId(); @Override LoggingObjectType getObjectType(); TransLogTable getTransLogTable(); void setTransLogTable( TransLogTable transLogTable ); PerformanceLogTable getPerformanceLogTable(); void setPerformanceLogTable( PerformanceLogTable performanceLogTable ); StepLogTable getStepLogTable(); void setStepLogTable( StepLogTable stepLogTable ); List<LogTableInterface> getLogTables(); TransformationType getTransformationType(); void setTransformationType( TransformationType transformationType ); void writeXML( String filename ); boolean hasRepositoryReferences(); void lookupRepositoryReferences( Repository repository ); MetricsLogTable getMetricsLogTable(); void setMetricsLogTable( MetricsLogTable metricsLogTable ); @Override boolean isGatheringMetrics(); @Override void setGatheringMetrics( boolean gatheringMetrics ); @Override boolean isForcingSeparateLogging(); @Override void setForcingSeparateLogging( boolean forcingSeparateLogging ); void addStepChangeListener( StepMetaChangeListenerInterface listener ); void addStepChangeListener( int p, StepMetaChangeListenerInterface list ); void removeStepChangeListener( StepMetaChangeListenerInterface list ); void notifyAllListeners( StepMeta oldMeta, StepMeta newMeta ); boolean containsStepMeta( StepMeta stepMeta ); List<MissingTrans> getMissingTrans(); void addMissingTrans( MissingTrans trans ); void removeMissingTrans( MissingTrans trans ); @Override boolean hasMissingPlugins(); @Override NamedClusterEmbedManager getNamedClusterEmbedManager( ); }
TransMeta extends AbstractMeta implements XMLInterface, Comparator<TransMeta>, Comparable<TransMeta>, Cloneable, ResourceExportInterface,
    RepositoryElementInterface, LoggingObjectInterface { public Object realClone( boolean doClear ) { try { TransMeta transMeta = (TransMeta) super.clone(); if ( doClear ) { transMeta.clear(); } else { transMeta.databases = new ArrayList<>(); transMeta.steps = new ArrayList<>(); transMeta.hops = new ArrayList<>(); transMeta.notes = new ArrayList<>(); transMeta.dependencies = new ArrayList<>(); transMeta.partitionSchemas = new ArrayList<>(); transMeta.slaveServers = new ArrayList<>(); transMeta.clusterSchemas = new ArrayList<>(); transMeta.namedParams = new NamedParamsDefault(); transMeta.stepChangeListeners = new ArrayList<>(); } for ( DatabaseMeta db : databases ) { transMeta.addDatabase( (DatabaseMeta) db.clone() ); } for ( StepMeta step : steps ) { transMeta.addStep( (StepMeta) step.clone() ); } for ( StepMeta step : transMeta.getSteps() ) { final StepMetaInterface stepMetaInterface = step.getStepMetaInterface(); if ( stepMetaInterface != null ) { final StepIOMetaInterface stepIOMeta = stepMetaInterface.getStepIOMeta(); if ( stepIOMeta != null ) { for ( StreamInterface stream : stepIOMeta.getInfoStreams() ) { String streamStepName = stream.getStepname(); if ( streamStepName != null ) { StepMeta streamStepMeta = transMeta.findStep( streamStepName ); stream.setStepMeta( streamStepMeta ); } } } } } for ( TransHopMeta hop : hops ) { transMeta.addTransHop( (TransHopMeta) hop.clone() ); } for ( NotePadMeta note : notes ) { transMeta.addNote( (NotePadMeta) note.clone() ); } for ( TransDependency dep : dependencies ) { transMeta.addDependency( (TransDependency) dep.clone() ); } for ( SlaveServer slave : slaveServers ) { transMeta.getSlaveServers().add( (SlaveServer) slave.clone() ); } for ( ClusterSchema schema : clusterSchemas ) { transMeta.getClusterSchemas().add( schema.clone() ); } for ( PartitionSchema schema : partitionSchemas ) { transMeta.getPartitionSchemas().add( (PartitionSchema) schema.clone() ); } for ( String key : listParameters() ) { transMeta.addParameterDefinition( key, getParameterDefault( key ), getParameterDescription( key ) ); } return transMeta; } catch ( Exception e ) { e.printStackTrace(); return null; } } TransMeta();  TransMeta( VariableSpace parent );  TransMeta( String filename, String name ); @Deprecated  TransMeta( String filename, String name, String[] arguments );  TransMeta( String fname );  TransMeta( String fname, VariableSpace parentVariableSpace );  TransMeta( String fname, boolean setInternalVariables );  TransMeta( String fname, Repository rep );  TransMeta( String fname, Repository rep, boolean setInternalVariables );  TransMeta( String fname, Repository rep, boolean setInternalVariables, VariableSpace parentVariableSpace );  TransMeta( String fname, Repository rep, boolean setInternalVariables, VariableSpace parentVariableSpace,
      OverwritePrompter prompter );  TransMeta( String fname, IMetaStore metaStore, Repository rep, boolean setInternalVariables,
                    VariableSpace parentVariableSpace, OverwritePrompter prompter );  TransMeta( InputStream xmlStream, Repository rep, boolean setInternalVariables,
                    VariableSpace parentVariableSpace, OverwritePrompter prompter );  TransMeta( Node transnode, Repository rep ); @Override int compare( TransMeta t1, TransMeta t2 ); @Override int compareTo( TransMeta o ); @Override boolean equals( Object obj ); @Override Object clone(); Object realClone( boolean doClear ); @Override void clear(); void addStep( StepMeta stepMeta ); void addOrReplaceStep( StepMeta stepMeta ); void addTransHop( TransHopMeta hi ); void addDependency( TransDependency td ); void addStep( int p, StepMeta stepMeta ); void addTransHop( int p, TransHopMeta hi ); void addDependency( int p, TransDependency td ); List<StepMeta> getSteps(); StepMeta getStep( int i ); TransHopMeta getTransHop( int i ); TransDependency getDependency( int i ); void removeStep( int i ); void removeTransHop( int i ); void removeTransHop( TransHopMeta hop ); void removeDependency( int i ); void removeAllDependencies(); int nrSteps(); int nrTransHops(); int nrDependencies(); int nrStepChangeListeners(); void setStep( int i, StepMeta stepMeta ); void setTransHop( int i, TransHopMeta hi ); List<StepMeta> getUsedSteps(); StepMeta findStep( String name ); StepMeta findStep( String name, StepMeta exclude ); TransHopMeta findTransHop( String name ); TransHopMeta findTransHopFrom( StepMeta fromstep ); List<TransHopMeta> findAllTransHopFrom( StepMeta fromstep ); TransHopMeta findTransHop( TransHopMeta hi ); TransHopMeta findTransHop( StepMeta from, StepMeta to ); TransHopMeta findTransHop( StepMeta from, StepMeta to, boolean disabledToo ); TransHopMeta findTransHopTo( StepMeta tostep ); boolean isStepInformative( StepMeta this_step, StepMeta prev_step ); @Deprecated int findNrPrevSteps( String stepname ); @Deprecated int findNrPrevSteps( String stepname, boolean info ); int findNrPrevSteps( StepMeta stepMeta ); @Deprecated StepMeta findPrevStep( String stepname, int nr ); @Deprecated StepMeta findPrevStep( String stepname, int nr, boolean info ); StepMeta findPrevStep( StepMeta stepMeta, int nr ); @Deprecated int findNrPrevSteps( StepMeta stepMeta, boolean info ); @Deprecated StepMeta findPrevStep( StepMeta stepMeta, int nr, boolean info ); List<StepMeta> findPreviousSteps( StepMeta stepMeta ); List<StepMeta> findPreviousSteps( StepMeta stepMeta, boolean info ); StepMeta[] getInfoStep( StepMeta stepMeta ); int findNrInfoSteps( StepMeta stepMeta ); RowMetaInterface getPrevInfoFields( String stepname ); RowMetaInterface getPrevInfoFields( StepMeta stepMeta ); @Deprecated int findNrNextSteps( StepMeta stepMeta ); @Deprecated StepMeta findNextStep( StepMeta stepMeta, int nr ); StepMeta[] getPrevSteps( StepMeta stepMeta ); String[] getPrevStepNames( String stepname ); String[] getPrevStepNames( StepMeta stepMeta ); @Deprecated StepMeta[] getNextSteps( StepMeta stepMeta ); List<StepMeta> findNextSteps( StepMeta stepMeta ); String[] getNextStepNames( StepMeta stepMeta ); StepMeta getStep( int x, int y, int iconsize ); boolean partOfTransHop( StepMeta stepMeta ); RowMetaInterface getStepFields( String stepname ); RowMetaInterface getStepFields( StepMeta stepMeta ); RowMetaInterface getStepFields( StepMeta[] stepMeta ); RowMetaInterface getStepFields( StepMeta stepMeta, ProgressMonitorListener monitor ); RowMetaInterface getStepFields( StepMeta stepMeta, StepMeta targetStep, ProgressMonitorListener monitor ); RowMetaInterface getPrevStepFields( String stepname ); RowMetaInterface getPrevStepFields( StepMeta stepMeta ); RowMetaInterface getPrevStepFields( StepMeta stepMeta, ProgressMonitorListener monitor ); RowMetaInterface getThisStepFields( String stepname, RowMetaInterface row ); RowMetaInterface getThisStepFields( StepMeta stepMeta, StepMeta nextStep, RowMetaInterface row ); RowMetaInterface getThisStepFields( StepMeta stepMeta, StepMeta nextStep, RowMetaInterface row,
      ProgressMonitorListener monitor ); boolean isUsingPartitionSchema( PartitionSchema partitionSchema ); boolean isUsingAClusterSchema(); boolean isUsingClusterSchema( ClusterSchema clusterSchema ); boolean isUsingSlaveServer( SlaveServer slaveServer ); boolean isRepReference(); boolean isFileReference(); static boolean isRepReference( String exactFilename, String exactTransname ); static boolean isFileReference( String exactFilename, String exactTransname ); int indexOfTransHop( TransHopMeta hi ); int indexOfStep( StepMeta stepMeta ); @Override String getFileType(); @Override String[] getFilterNames(); @Override String[] getFilterExtensions(); @Override String getDefaultExtension(); @Override String getXML(); String getXML( boolean includeSteps, boolean includeDatabase, boolean includeSlaves, boolean includeClusters,
      boolean includePartitions ); void loadXML( Node transnode, Repository rep, boolean setInternalVariables ); void loadXML( Node transnode, Repository rep, boolean setInternalVariables, VariableSpace parentVariableSpace ); void loadXML( Node transnode, Repository rep, boolean setInternalVariables, VariableSpace parentVariableSpace,
      OverwritePrompter prompter ); void loadXML( Node transnode, String fname, Repository rep, boolean setInternalVariables,
                       VariableSpace parentVariableSpace, OverwritePrompter prompter ); void loadXML( Node transnode, String fname, IMetaStore metaStore, Repository rep, boolean setInternalVariables,
                       VariableSpace parentVariableSpace, OverwritePrompter prompter ); byte[] getKey(); void setKey( byte[] key ); boolean isPrivateKey(); void setPrivateKey( boolean privateKey ); @Override boolean loadSharedObject( SharedObjectInterface object ); List<StepMeta> getTransHopSteps( boolean all ); boolean isStepUsedInTransHops( StepMeta stepMeta ); boolean isAnySelectedStepUsedInTransHops(); @Override void clearChanged(); boolean haveStepsChanged(); boolean haveHopsChanged(); boolean havePartitionSchemasChanged(); boolean haveClusterSchemasChanged(); @Override boolean hasChanged(); boolean hasLoop( StepMeta stepMeta ); void selectAll(); void unselectAll(); Point[] getSelectedStepLocations(); Point[] getSelectedNoteLocations(); List<StepMeta> getSelectedSteps(); String[] getSelectedStepNames(); int[] getStepIndexes( List<StepMeta> steps ); Point getMaximum(); Point getMinimum(); String[] getStepNames(); StepMeta[] getStepsArray(); boolean findPrevious( StepMeta startStep, StepMeta stepToFind ); void sortSteps(); void sortHops(); Map<StepMeta, Map<StepMeta, Boolean>> sortStepsNatural(); void sortHopsNatural(); void analyseImpact( List<DatabaseImpact> impact, ProgressMonitorListener monitor ); String getAlternativeStepname( String stepname ); List<SQLStatement> getSQLStatements(); List<SQLStatement> getSQLStatements( ProgressMonitorListener monitor ); String getSQLStatementsString(); @Deprecated void checkSteps( List<CheckResultInterface> remarks, boolean only_selected, ProgressMonitorListener monitor ); void checkSteps( List<CheckResultInterface> remarks, boolean only_selected, ProgressMonitorListener monitor,
      VariableSpace space, Repository repository, IMetaStore metaStore ); @Deprecated List<RowMetaAndData> getResultRows(); @Deprecated void setResultRows( List<RowMetaAndData> resultRows ); String getPathAndName(); @Deprecated String[] getArguments(); @Deprecated void setArguments( String[] arguments ); @Deprecated Hashtable<String, Counter> getCounters(); @Deprecated void setCounters( Hashtable<String, Counter> counters ); List<TransDependency> getDependencies(); void setDependencies( List<TransDependency> dependencies ); DatabaseMeta getMaxDateConnection(); void setMaxDateConnection( DatabaseMeta maxDateConnection ); double getMaxDateDifference(); void setMaxDateDifference( double maxDateDifference ); String getMaxDateField(); void setMaxDateField( String maxDateField ); double getMaxDateOffset(); void setMaxDateOffset( double maxDateOffset ); String getMaxDateTable(); void setMaxDateTable( String maxDateTable ); int getSizeRowset(); void setSizeRowset( int sizeRowset ); DBCache getDbCache(); void setDbCache( DBCache dbCache ); String getTransversion(); void setTransversion( String n ); void setTransstatus( int n ); int getTransstatus(); @Override String toString(); void cancelQueries(); Map<String, String> getUsedArguments( String[] arguments ); int getSleepTimeEmpty(); int getSleepTimeFull(); void setSleepTimeEmpty( int sleepTimeEmpty ); void setSleepTimeFull( int sleepTimeFull ); boolean isDatabaseConnectionUsed( DatabaseMeta databaseMeta ); List<StringSearchResult> getStringList( boolean searchSteps, boolean searchDatabases, boolean searchNotes,
      boolean includePasswords ); List<StringSearchResult> getStringList( boolean searchSteps, boolean searchDatabases, boolean searchNotes ); List<String> getUsedVariables(); @Deprecated Result getPreviousResult(); @Deprecated void setPreviousResult( Result previousResult ); @Deprecated List<ResultFile> getResultFiles(); @Deprecated void setResultFiles( List<ResultFile> resultFiles ); List<PartitionSchema> getPartitionSchemas(); void setPartitionSchemas( List<PartitionSchema> partitionSchemas ); String[] getPartitionSchemasNames(); boolean isFeedbackShown(); void setFeedbackShown( boolean feedbackShown ); int getFeedbackSize(); void setFeedbackSize( int feedbackSize ); boolean isUsingUniqueConnections(); void setUsingUniqueConnections( boolean usingUniqueConnections ); List<ClusterSchema> getClusterSchemas(); void setClusterSchemas( List<ClusterSchema> clusterSchemas ); String[] getClusterSchemaNames(); PartitionSchema findPartitionSchema( String name ); ClusterSchema findClusterSchema( String name ); void addOrReplacePartitionSchema( PartitionSchema partitionSchema ); void addOrReplaceClusterSchema( ClusterSchema clusterSchema ); boolean isUsingThreadPriorityManagment(); void setUsingThreadPriorityManagment( boolean usingThreadPriorityManagment ); void checkRowMixingStatically( StepMeta stepMeta, ProgressMonitorListener monitor ); @Override void setInternalKettleVariables( VariableSpace var ); StepMeta findMappingInputStep( String stepname ); StepMeta findMappingOutputStep( String stepname ); List<ResourceReference> getResourceDependencies(); @Override String exportResources( VariableSpace space, Map<String, ResourceDefinition> definitions,
      ResourceNamingInterface resourceNamingInterface, Repository repository, IMetaStore metaStore ); SlaveStepCopyPartitionDistribution getSlaveStepCopyPartitionDistribution(); void setSlaveStepCopyPartitionDistribution(
      SlaveStepCopyPartitionDistribution slaveStepCopyPartitionDistribution ); ClusterSchema findFirstUsedClusterSchema(); boolean isSlaveTransformation(); void setSlaveTransformation( boolean slaveTransformation ); boolean isCapturingStepPerformanceSnapShots(); void setCapturingStepPerformanceSnapShots( boolean capturingStepPerformanceSnapShots ); long getStepPerformanceCapturingDelay(); void setStepPerformanceCapturingDelay( long stepPerformanceCapturingDelay ); String getStepPerformanceCapturingSizeLimit(); void setStepPerformanceCapturingSizeLimit( String stepPerformanceCapturingSizeLimit ); void clearCaches(); @Override RepositoryObjectType getRepositoryElementType(); LogChannelInterface getLogChannel(); @Override String getLogChannelId(); @Override LoggingObjectType getObjectType(); TransLogTable getTransLogTable(); void setTransLogTable( TransLogTable transLogTable ); PerformanceLogTable getPerformanceLogTable(); void setPerformanceLogTable( PerformanceLogTable performanceLogTable ); StepLogTable getStepLogTable(); void setStepLogTable( StepLogTable stepLogTable ); List<LogTableInterface> getLogTables(); TransformationType getTransformationType(); void setTransformationType( TransformationType transformationType ); void writeXML( String filename ); boolean hasRepositoryReferences(); void lookupRepositoryReferences( Repository repository ); MetricsLogTable getMetricsLogTable(); void setMetricsLogTable( MetricsLogTable metricsLogTable ); @Override boolean isGatheringMetrics(); @Override void setGatheringMetrics( boolean gatheringMetrics ); @Override boolean isForcingSeparateLogging(); @Override void setForcingSeparateLogging( boolean forcingSeparateLogging ); void addStepChangeListener( StepMetaChangeListenerInterface listener ); void addStepChangeListener( int p, StepMetaChangeListenerInterface list ); void removeStepChangeListener( StepMetaChangeListenerInterface list ); void notifyAllListeners( StepMeta oldMeta, StepMeta newMeta ); boolean containsStepMeta( StepMeta stepMeta ); List<MissingTrans> getMissingTrans(); void addMissingTrans( MissingTrans trans ); void removeMissingTrans( MissingTrans trans ); @Override boolean hasMissingPlugins(); @Override NamedClusterEmbedManager getNamedClusterEmbedManager( ); static final String XML_TAG; static final String STRING_TRANSMETA; static final RepositoryObjectType REPOSITORY_ELEMENT_TYPE; static final int BORDER_INDENT; static final String[] desc_type_undo; static final String XML_TAG_ORDER; static final String XML_TAG_NOTEPADS; static final String XML_TAG_PARAMETERS; static final String XML_TAG_PARTITIONSCHEMAS; static final String XML_TAG_SLAVESERVERS; static final String XML_TAG_CLUSTERSCHEMAS; static final String XML_TAG_STEP_ERROR_HANDLING; }