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 void
afterInjectionSynchronization()
If we use injection we can have different arrays lengths.void
allocate(int nrfields)
void
assignSortingCriteria(org.pentaho.di.core.row.RowMetaInterface inputRowMeta)
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)
Checks the settings of this step and puts the findings in a remarks List.Object
clone()
Make an exact copy of this step, make sure to explicitly copy Collections etc.boolean[]
getAscending()
boolean[]
getCaseSensitive()
boolean[]
getCollatorEnabled()
int[]
getCollatorStrength()
boolean
getCompressFiles()
String
getCompressFilesVariable()
String
getDirectory()
String[]
getFieldName()
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)
Gets the fields.String
getFreeMemoryLimit()
List<String>
getGroupFields()
String
getPrefix()
boolean[]
getPreSortedField()
String
getSortSize()
StepInterface
getStep(StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta transMeta, Trans trans)
Get the executing step, needed by Trans to launch a step.StepDataInterface
getStepData()
Get a new instance of the appropriate data class.String
getXML()
Produces the XML string that describes this step's information.boolean
isGroupSortEnabled()
boolean
isOnlyPassingUniqueRows()
void
loadXML(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 Nodevoid
readRep(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 void
registerUrlWithDirectory()
void
saveRep(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 repositoryvoid
setAscending(boolean[] ascending)
void
setCaseSensitive(boolean[] caseSensitive)
void
setCollatorEnabled(boolean[] collatorEnabled)
void
setCollatorStrength(int[] collatorStrength)
void
setCompressFiles(boolean compressFiles)
void
setCompressFilesVariable(String compressFilesVariable)
void
setDefault()
Set default valuesvoid
setDirectory(String directory)
void
setFieldName(String[] fieldName)
void
setFreeMemoryLimit(String freeMemoryLimit)
void
setOnlyPassingUniqueRows(boolean onlyPassingUniqueRows)
void
setPrefix(String prefix)
void
setPreSortedField(boolean[] preSorted)
void
setSortSize(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:StepMetaInterface
Load the values for this step from an XML Node- Specified by:
loadXML
in interfaceStepMetaInterface
- Overrides:
loadXML
in 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:StepMetaInterface
Make an exact copy of this step, make sure to explicitly copy Collections etc.- Specified by:
clone
in interfaceStepMetaInterface
- Overrides:
clone
in classBaseStepMeta
- Returns:
- an exact copy of this step
-
setDefault
public void setDefault()
Description copied from interface:StepMetaInterface
Set default values- Specified by:
setDefault
in interfaceStepMetaInterface
-
registerUrlWithDirectory
protected void registerUrlWithDirectory()
-
getXML
public String getXML()
Description copied from class:BaseStepMeta
Produces the XML string that describes this step's information.- Specified by:
getXML
in interfaceStepMetaInterface
- Overrides:
getXML
in 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:StepMetaInterface
Read the steps information from a Kettle repository- Specified by:
readRep
in interfaceStepMetaInterface
- Overrides:
readRep
in 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:StepMetaInterface
Save the steps data into a Kettle repository- Specified by:
saveRep
in interfaceStepMetaInterface
- Overrides:
saveRep
in 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.KettleStepException
Description copied from class:BaseStepMeta
Gets the fields.- Specified by:
getFields
in interfaceStepMetaInterface
- Overrides:
getFields
in 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:StepMetaInterface
Checks the settings of this step and puts the findings in a remarks List.- Specified by:
check
in interfaceStepMetaInterface
- Overrides:
check
in 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:StepMetaInterface
Get the executing step, needed by Trans to launch a step.- Specified by:
getStep
in 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:StepMetaInterface
Get 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:
getStepData
in 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
-
-