Package org.pentaho.di.trans.steps.sort
Class SortRowsMeta
- java.lang.Object
-
- org.pentaho.di.trans.step.BaseStepMeta
-
- org.pentaho.di.trans.steps.sort.SortRowsMeta
-
- All Implemented Interfaces:
Serializable,Cloneable,StepAttributesInterface,StepMetaInterface
public class SortRowsMeta extends BaseStepMeta implements StepMetaInterface, Serializable
- See Also:
- Serialized Form
-
-
Field Summary
-
Fields inherited from class org.pentaho.di.trans.step.BaseStepMeta
attributes, databases, log, loggingObject, parentStepMeta, repository, STEP_ATTRIBUTES_FILE
-
-
Constructor Summary
Constructors Constructor Description SortRowsMeta()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidafterInjectionSynchronization()If we use injection we can have different arrays lengths.voidallocate(int nrfields)voidassignSortingCriteria(org.pentaho.di.core.row.RowMetaInterface inputRowMeta)voidcheck(List<org.pentaho.di.core.CheckResultInterface> remarks, TransMeta transMeta, StepMeta stepMeta, org.pentaho.di.core.row.RowMetaInterface prev, String[] input, String[] output, org.pentaho.di.core.row.RowMetaInterface info, org.pentaho.di.core.variables.VariableSpace space, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore)Checks the settings of this step and puts the findings in a remarks List.Objectclone()Make an exact copy of this step, make sure to explicitly copy Collections etc.boolean[]getAscending()boolean[]getCaseSensitive()boolean[]getCollatorEnabled()int[]getCollatorStrength()booleangetCompressFiles()StringgetCompressFilesVariable()StringgetDirectory()String[]getFieldName()voidgetFields(org.pentaho.di.core.row.RowMetaInterface inputRowMeta, String name, org.pentaho.di.core.row.RowMetaInterface[] info, StepMeta nextStep, org.pentaho.di.core.variables.VariableSpace space, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore)Gets the fields.StringgetFreeMemoryLimit()List<String>getGroupFields()StringgetPrefix()boolean[]getPreSortedField()StringgetSortSize()StepInterfacegetStep(StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta transMeta, Trans trans)Get the executing step, needed by Trans to launch a step.StepDataInterfacegetStepData()Get a new instance of the appropriate data class.StringgetXML()Produces the XML string that describes this step's information.booleanisGroupSortEnabled()booleanisOnlyPassingUniqueRows()voidloadXML(Node stepnode, List<org.pentaho.di.core.database.DatabaseMeta> databases, org.pentaho.metastore.api.IMetaStore metaStore)Load the values for this step from an XML NodevoidreadRep(Repository rep, org.pentaho.metastore.api.IMetaStore metaStore, org.pentaho.di.repository.ObjectId id_step, List<org.pentaho.di.core.database.DatabaseMeta> databases)Read the steps information from a Kettle repositoryprotected voidregisterUrlWithDirectory()voidsaveRep(Repository rep, org.pentaho.metastore.api.IMetaStore metaStore, org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step)Save the steps data into a Kettle repositoryvoidsetAscending(boolean[] ascending)voidsetCaseSensitive(boolean[] caseSensitive)voidsetCollatorEnabled(boolean[] collatorEnabled)voidsetCollatorStrength(int[] collatorStrength)voidsetCompressFiles(boolean compressFiles)voidsetCompressFilesVariable(String compressFilesVariable)voidsetDefault()Set default valuesvoidsetDirectory(String directory)voidsetFieldName(String[] fieldName)voidsetFreeMemoryLimit(String freeMemoryLimit)voidsetOnlyPassingUniqueRows(boolean onlyPassingUniqueRows)voidsetPrefix(String prefix)voidsetPreSortedField(boolean[] preSorted)voidsetSortSize(String sortSize)-
Methods inherited from class org.pentaho.di.trans.step.BaseStepMeta
analyseImpact, analyseImpact, cancelQueries, check, check, createEntry, excludeFromCopyDistributeVerification, excludeFromRowLayoutVerification, exportResources, exportResources, extractStepMetadataEntries, findAttribute, findParent, findParentEntry, getActiveReferencedObjectDescription, getDescription, getDialogClassName, getFields, getLog, getLogChannelId, getName, getObjectCopy, getObjectId, getObjectRevision, getObjectType, getOptionalStreams, getParent, getParentStepMeta, getReferencedObjectDescriptions, getRepCode, getRepositoryDirectory, getRequiredFields, getRequiredFields, getResourceDependencies, getSQLStatements, getSQLStatements, getStepInjectionMetadataEntries, getStepIOMeta, getStepIOMeta, getStepMetaInjectionInterface, getSupportedTransformationTypes, getTableFields, getTooltip, getUsedArguments, getUsedDatabaseConnections, getUsedLibraries, getXmlCode, handleStreamSelection, hasChanged, hasRepositoryReferences, isBasic, isDebug, isDetailed, isReferencedObjectEnabled, isRowLevel, loadReferencedObject, loadReferencedObject, loadStepAttributes, loadXML, loadXML, logBasic, logBasic, logDebug, logDebug, logDetailed, logDetailed, logError, logError, logError, logMinimal, logMinimal, logRowlevel, logRowlevel, lookupRepositoryReferences, readRep, readRep, resetStepIoMeta, saveRep, searchInfoAndTargetSteps, setChanged, setChanged, setParentStepMeta, setStepIOMeta, supportsErrorHandling
-
Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.pentaho.di.trans.step.StepMetaInterface
analyseImpact, analyseImpact, cancelQueries, check, cleanAfterHopFromRemove, cleanAfterHopFromRemove, cleanAfterHopToRemove, excludeFromCopyDistributeVerification, excludeFromRowLayoutVerification, exportResources, exportResources, extractStepMetadataEntries, fetchTransMeta, getActiveReferencedObjectDescription, getDialogClassName, getFields, getOptionalStreams, getParentStepMeta, getReferencedObjectDescriptions, getRequiredFields, getResourceDependencies, getSQLStatements, getSQLStatements, getStepIOMeta, getStepMetaInjectionInterface, getSupportedTransformationTypes, getTableFields, getUsedArguments, getUsedDatabaseConnections, getUsedLibraries, handleStreamSelection, hasChanged, hasRepositoryReferences, isReferencedObjectEnabled, loadReferencedObject, loadXML, lookupRepositoryReferences, passDataToServletOutput, readRep, resetStepIoMeta, saveRep, searchInfoAndTargetSteps, setChanged, setParentStepMeta, supportsErrorHandling
-
-
-
-
Method Detail
-
getAscending
public boolean[] getAscending()
- Returns:
- Returns the ascending.
-
setAscending
public void setAscending(boolean[] ascending)
- Parameters:
ascending- The ascending to set.
-
getDirectory
public String getDirectory()
- Returns:
- Returns the directory.
-
setDirectory
public void setDirectory(String directory)
- Parameters:
directory- The directory to set.
-
getFieldName
public String[] getFieldName()
- Returns:
- Returns the fieldName.
-
setFieldName
public void setFieldName(String[] fieldName)
- Parameters:
fieldName- The fieldName to set.
-
getPrefix
public String getPrefix()
- Returns:
- Returns the prefix.
-
setPrefix
public void setPrefix(String prefix)
- Parameters:
prefix- The prefix to set.
-
loadXML
public void loadXML(Node stepnode, List<org.pentaho.di.core.database.DatabaseMeta> databases, org.pentaho.metastore.api.IMetaStore metaStore) throws org.pentaho.di.core.exception.KettleXMLException
Description copied from interface:StepMetaInterfaceLoad the values for this step from an XML Node- Specified by:
loadXMLin interfaceStepMetaInterface- Overrides:
loadXMLin classBaseStepMeta- Parameters:
stepnode- the Node to get the info fromdatabases- The available list of databases to reference tometaStore- the metastore to optionally load external reference metadata from- Throws:
org.pentaho.di.core.exception.KettleXMLException- When an unexpected XML error occurred. (malformed etc.)
-
allocate
public void allocate(int nrfields)
-
clone
public Object clone()
Description copied from interface:StepMetaInterfaceMake an exact copy of this step, make sure to explicitly copy Collections etc.- Specified by:
clonein interfaceStepMetaInterface- Overrides:
clonein classBaseStepMeta- Returns:
- an exact copy of this step
-
setDefault
public void setDefault()
Description copied from interface:StepMetaInterfaceSet default values- Specified by:
setDefaultin interfaceStepMetaInterface
-
registerUrlWithDirectory
protected void registerUrlWithDirectory()
-
getXML
public String getXML()
Description copied from class:BaseStepMetaProduces the XML string that describes this step's information.- Specified by:
getXMLin interfaceStepMetaInterface- Overrides:
getXMLin classBaseStepMeta- Returns:
- String containing the XML describing this step.
-
readRep
public void readRep(Repository rep, org.pentaho.metastore.api.IMetaStore metaStore, org.pentaho.di.repository.ObjectId id_step, List<org.pentaho.di.core.database.DatabaseMeta> databases) throws org.pentaho.di.core.exception.KettleException
Description copied from interface:StepMetaInterfaceRead the steps information from a Kettle repository- Specified by:
readRepin interfaceStepMetaInterface- Overrides:
readRepin classBaseStepMeta- Parameters:
rep- The repository to read frommetaStore- The MetaStore to read external information fromid_step- The step IDdatabases- The databases to reference- Throws:
org.pentaho.di.core.exception.KettleException- When an unexpected error occurred (database, network, etc)
-
saveRep
public void saveRep(Repository rep, org.pentaho.metastore.api.IMetaStore metaStore, org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step) throws org.pentaho.di.core.exception.KettleException
Description copied from interface:StepMetaInterfaceSave the steps data into a Kettle repository- Specified by:
saveRepin interfaceStepMetaInterface- Overrides:
saveRepin classBaseStepMeta- Parameters:
rep- The Kettle repository to save tometaStore- the metaStore to optionally write toid_transformation- The transformation IDid_step- The step ID- Throws:
org.pentaho.di.core.exception.KettleException- When an unexpected error occurred (database, network, etc)
-
getFields
public void getFields(org.pentaho.di.core.row.RowMetaInterface inputRowMeta, String name, org.pentaho.di.core.row.RowMetaInterface[] info, StepMeta nextStep, org.pentaho.di.core.variables.VariableSpace space, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore) throws org.pentaho.di.core.exception.KettleStepExceptionDescription copied from class:BaseStepMetaGets the fields.- Specified by:
getFieldsin interfaceStepMetaInterface- Overrides:
getFieldsin classBaseStepMeta- Parameters:
inputRowMeta- the input row meta that is modified in this method to reflect the output row metadata of the stepname- Name of the step to use as input for the origin field in the valuesinfo- Fields used as extra lookup informationnextStep- the next step that is targetedspace- the space The variable space to use to replace variablesrepository- the repository to use to load Kettle metadata objects impacting the output fieldsmetaStore- the MetaStore to use to load additional external data or metadata impacting the output fields- Throws:
org.pentaho.di.core.exception.KettleStepException- the kettle step exception
-
assignSortingCriteria
public void assignSortingCriteria(org.pentaho.di.core.row.RowMetaInterface inputRowMeta)
-
check
public void check(List<org.pentaho.di.core.CheckResultInterface> remarks, TransMeta transMeta, StepMeta stepMeta, org.pentaho.di.core.row.RowMetaInterface prev, String[] input, String[] output, org.pentaho.di.core.row.RowMetaInterface info, org.pentaho.di.core.variables.VariableSpace space, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore)
Description copied from interface:StepMetaInterfaceChecks the settings of this step and puts the findings in a remarks List.- Specified by:
checkin interfaceStepMetaInterface- Overrides:
checkin classBaseStepMeta- Parameters:
remarks- The list to put the remarks in @see org.pentaho.di.core.CheckResultstepMeta- The stepMeta to help checkingprev- The fields coming from the previous stepinput- The input step namesoutput- The output step namesinfo- The fields that are used as information by the stepspace- the variable space to resolve variable expressions withrepository- the repository to use to load Kettle metadata objects impacting the output fieldsmetaStore- the MetaStore to use to load additional external data or metadata impacting the output fields
-
getStep
public StepInterface getStep(StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta transMeta, Trans trans)
Description copied from interface:StepMetaInterfaceGet the executing step, needed by Trans to launch a step.- Specified by:
getStepin interfaceStepMetaInterface- Parameters:
stepMeta- The step infostepDataInterface- the step data interface linked to this step. Here the step can store temporary data, database connections, etc.cnr- The copy nr to gettransMeta- The transformation infotrans- The launching transformation
-
getStepData
public StepDataInterface getStepData()
Description copied from interface:StepMetaInterfaceGet a new instance of the appropriate data class. This data class implements the StepDataInterface. It basically contains the persisting data that needs to live on, even if a worker thread is terminated.- Specified by:
getStepDatain interfaceStepMetaInterface- Returns:
- The appropriate StepDataInterface class.
-
getSortSize
public String getSortSize()
- Returns:
- Returns the sortSize.
-
setSortSize
public void setSortSize(String sortSize)
- Parameters:
sortSize- The sortSize to set.
-
getCompressFiles
public boolean getCompressFiles()
- Returns:
- Returns whether temporary files should be compressed
-
setCompressFiles
public void setCompressFiles(boolean compressFiles)
- Parameters:
compressFiles- Whether to compress temporary files created during sorting
-
isOnlyPassingUniqueRows
public boolean isOnlyPassingUniqueRows()
- Returns:
- the onlyPassingUniqueRows
-
setOnlyPassingUniqueRows
public void setOnlyPassingUniqueRows(boolean onlyPassingUniqueRows)
- Parameters:
onlyPassingUniqueRows- the onlyPassingUniqueRows to set
-
getCompressFilesVariable
public String getCompressFilesVariable()
- Returns:
- the compressFilesVariable
-
setCompressFilesVariable
public void setCompressFilesVariable(String compressFilesVariable)
- Parameters:
compressFilesVariable- the compressFilesVariable to set
-
getCaseSensitive
public boolean[] getCaseSensitive()
- Returns:
- the caseSensitive
-
setCaseSensitive
public void setCaseSensitive(boolean[] caseSensitive)
- Parameters:
caseSensitive- the caseSensitive to set
-
getCollatorEnabled
public boolean[] getCollatorEnabled()
- Returns:
- the collatorEnabled
-
setCollatorEnabled
public void setCollatorEnabled(boolean[] collatorEnabled)
- Parameters:
collatorEnabled- the collatorEnabled to set
-
getCollatorStrength
public int[] getCollatorStrength()
- Returns:
- the collatorStrength
-
setCollatorStrength
public void setCollatorStrength(int[] collatorStrength)
- Parameters:
collatorStrength- the collatorStrength to set
-
getFreeMemoryLimit
public String getFreeMemoryLimit()
- Returns:
- the freeMemoryLimit
-
setFreeMemoryLimit
public void setFreeMemoryLimit(String freeMemoryLimit)
- Parameters:
freeMemoryLimit- the freeMemoryLimit to set
-
getPreSortedField
public boolean[] getPreSortedField()
- Returns:
- the preSortedField
-
setPreSortedField
public void setPreSortedField(boolean[] preSorted)
- Parameters:
preSorted- the preSorteField to set
-
isGroupSortEnabled
public boolean isGroupSortEnabled()
-
afterInjectionSynchronization
public void afterInjectionSynchronization()
If we use injection we can have different arrays lengths. We need synchronize them for consistency behavior with UI
-
-