|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.pentaho.di.trans.step.BaseStepMeta
public class BaseStepMeta
This class is responsible for implementing common functionality regarding step meta, such as logging. All Kettle steps have an extension of this where private fields have been added with public accessors.
For example, the "Text File Output" step's TextFileOutputMeta class extends BaseStepMeta by adding fields for the output file name, compression, file format, etc...
Field Summary | |
---|---|
static LoggingObjectInterface |
loggingObject
|
static String |
STEP_ATTRIBUTES_FILE
|
Constructor Summary | |
---|---|
BaseStepMeta()
Instantiates a new base step meta. |
Method Summary | |
---|---|
void |
analyseImpact(List<DatabaseImpact> impact,
TransMeta transMeta,
StepMeta stepMeta,
RowMetaInterface prev,
String[] input,
String[] output,
RowMetaInterface info)
Each step must be able to report on the impact it has on a database, table field, etc. |
void |
cancelQueries()
Call this to cancel trailing database queries (too long running, etc) |
Object |
clone()
|
boolean |
excludeFromCopyDistributeVerification()
This method is added to exclude certain steps from copy/distribute checking. |
boolean |
excludeFromRowLayoutVerification()
This method is added to exclude certain steps from layout checking. |
String |
exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Export resources. |
KettleAttributeInterface |
findAttribute(String key)
|
KettleAttributeInterface |
findParent(List<KettleAttributeInterface> attributes,
String parentId)
|
String |
getDescription(String attributeKey)
|
String |
getDialogClassName()
This returns the expected name for the dialog that edits a job entry. |
void |
getFields(RowMetaInterface inputRowMeta,
String name,
RowMetaInterface[] info,
StepMeta nextStep,
VariableSpace space)
Gets the fields. |
LogChannelInterface |
getLog()
Gets the log. |
String |
getLogChannelId()
Gets the log channel id. |
String |
getName()
Gets the name. |
String |
getObjectCopy()
Gets the object copy. |
ObjectId |
getObjectId()
Gets the object id. |
ObjectRevision |
getObjectRevision()
Gets the object revision. |
LoggingObjectType |
getObjectType()
Gets the object type. |
List<StreamInterface> |
getOptionalStreams()
|
LoggingObjectInterface |
getParent()
Gets the parent. |
StepMeta |
getParentStepMeta()
Gets the parent step meta. |
String |
getRepCode(String attributeKey)
|
RepositoryDirectory |
getRepositoryDirectory()
Gets the repository directory. |
RowMetaInterface |
getRequiredFields()
Deprecated. |
RowMetaInterface |
getRequiredFields(VariableSpace space)
The natural way of data flow in a transformation is source-to-target. |
List<ResourceReference> |
getResourceDependencies(TransMeta transMeta,
StepMeta stepInfo)
Get a list of all the resource dependencies that the step is depending on. |
SQLStatement |
getSQLStatements(TransMeta transMeta,
StepMeta stepMeta,
RowMetaInterface prev)
Standard method to return one or more SQLStatement objects that the step needs in order to work correctly. |
List<StepInjectionMetaEntry> |
getStepInjectionMetadataEntries(Class<?> PKG)
Describe the metadata attributes that can be injected into this step metadata object. |
StepIOMetaInterface |
getStepIOMeta()
Returns the Input/Output metadata for this step. |
StepMetaInjectionInterface |
getStepMetaInjectionInterface()
|
TransMeta.TransformationType[] |
getSupportedTransformationTypes()
|
RowMetaInterface |
getTableFields()
Gets the table fields. |
String |
getTooltip(String attributeKey)
|
Map<String,String> |
getUsedArguments()
Default a step doesn't use any arguments. |
DatabaseMeta[] |
getUsedDatabaseConnections()
This method returns all the database connections that are used by the step. |
String[] |
getUsedLibraries()
|
String |
getXML()
Produces the XML string that describes this step's information. |
String |
getXmlCode(String attributeKey)
|
void |
handleStreamSelection(StreamInterface stream)
When an optional stream is selected, this method is called to handled the ETL metadata implications of that. |
boolean |
hasChanged()
Checks for changed. |
boolean |
hasRepositoryReferences()
|
boolean |
isBasic()
Checks if is basic. |
boolean |
isDebug()
Checks if is debug. |
boolean |
isDetailed()
Checks if is detailed. |
boolean |
isRowLevel()
Checks if is row level. |
void |
logBasic(String message)
Log basic. |
void |
logBasic(String message,
Object... arguments)
Log basic. |
void |
logDebug(String message)
Log debug. |
void |
logDebug(String message,
Object... arguments)
Log debug. |
void |
logDetailed(String message)
Log detailed. |
void |
logDetailed(String message,
Object... arguments)
Log detailed. |
void |
logError(String message)
Log error. |
void |
logError(String message,
Object... arguments)
Log error. |
void |
logError(String message,
Throwable e)
Log error. |
void |
logMinimal(String message)
Log minimal. |
void |
logMinimal(String message,
Object... arguments)
Log minimal. |
void |
logRowlevel(String message)
Log rowlevel. |
void |
logRowlevel(String message,
Object... arguments)
Log rowlevel. |
void |
lookupRepositoryReferences(Repository repository)
Look up the references after import |
void |
resetStepIoMeta()
Reset step io meta. |
void |
searchInfoAndTargetSteps(List<StepMeta> steps)
Change step names into step objects to allow them to be name-changed etc. |
void |
setChanged()
Sets the changed. |
void |
setChanged(boolean ch)
Sets the changed. |
void |
setParentStepMeta(StepMeta parentStepMeta)
Sets the parent step meta. |
boolean |
supportsErrorHandling()
|
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final LoggingObjectInterface loggingObject
public static final String STEP_ATTRIBUTES_FILE
Constructor Detail |
---|
public BaseStepMeta()
Method Detail |
---|
public Object clone()
clone
in class Object
public void setChanged(boolean ch)
ch
- the new changedpublic void setChanged()
public boolean hasChanged()
public RowMetaInterface getTableFields()
public String getXML() throws KettleException
KettleValueException
- in case there is an XML conversion or encoding error
KettleException
public void getFields(RowMetaInterface inputRowMeta, String name, RowMetaInterface[] info, StepMeta nextStep, VariableSpace space) throws KettleStepException
inputRowMeta
- the input row metaname
- the nameinfo
- the infonextStep
- the next stepspace
- the space
KettleStepException
- the kettle step exceptionpublic void analyseImpact(List<DatabaseImpact> impact, TransMeta transMeta, StepMeta stepMeta, RowMetaInterface prev, String[] input, String[] output, RowMetaInterface info) throws KettleStepException
impact
- The list of impacts @see org.pentaho.di.transMeta.DatabaseImpacttransMeta
- The transformation informationstepMeta
- The step informationprev
- The fields entering this stepinput
- The previous step namesoutput
- The output step namesinfo
- The fields used as information by this step
KettleStepException
public SQLStatement getSQLStatements(TransMeta transMeta, StepMeta stepMeta, RowMetaInterface prev) throws KettleStepException
transMeta
- TransInfo object containing the complete transformationstepMeta
- StepMeta object containing the complete stepprev
- Row containing meta-data for the input fields (no data)
KettleStepException
public void cancelQueries() throws KettleDatabaseException
KettleDatabaseException
public Map<String,String> getUsedArguments()
public RowMetaInterface getRequiredFields() throws KettleException
KettleException
- in case the required fields can't be determinedpublic RowMetaInterface getRequiredFields(VariableSpace space) throws KettleException
space
- the variable space to use to do variable substitution.
KettleException
- in case the required fields can't be determinedpublic DatabaseMeta[] getUsedDatabaseConnections()
public String[] getUsedLibraries()
public boolean supportsErrorHandling()
public boolean excludeFromRowLayoutVerification()
public boolean excludeFromCopyDistributeVerification()
public List<ResourceReference> getResourceDependencies(TransMeta transMeta, StepMeta stepInfo)
public String exportResources(VariableSpace space, Map<String,ResourceDefinition> definitions, ResourceNamingInterface resourceNamingInterface, Repository repository) throws KettleException
space
- the spacedefinitions
- the definitionsresourceNamingInterface
- the resource naming interfacerepository
- the repository
KettleException
- the kettle exceptionpublic String getDialogClassName()
public StepMeta getParentStepMeta()
public void setParentStepMeta(StepMeta parentStepMeta)
parentStepMeta
- the new parent step metapublic LogChannelInterface getLog()
public boolean isBasic()
public boolean isDetailed()
public boolean isDebug()
public boolean isRowLevel()
public void logMinimal(String message)
message
- the messagepublic void logMinimal(String message, Object... arguments)
message
- the messagearguments
- the argumentspublic void logBasic(String message)
message
- the messagepublic void logBasic(String message, Object... arguments)
message
- the messagearguments
- the argumentspublic void logDetailed(String message)
message
- the messagepublic void logDetailed(String message, Object... arguments)
message
- the messagearguments
- the argumentspublic void logDebug(String message)
message
- the messagepublic void logDebug(String message, Object... arguments)
message
- the messagearguments
- the argumentspublic void logRowlevel(String message)
message
- the messagepublic void logRowlevel(String message, Object... arguments)
message
- the messagearguments
- the argumentspublic void logError(String message)
message
- the messagepublic void logError(String message, Throwable e)
message
- the messagee
- the epublic void logError(String message, Object... arguments)
message
- the messagearguments
- the argumentspublic String getLogChannelId()
public String getName()
public String getObjectCopy()
public ObjectId getObjectId()
public ObjectRevision getObjectRevision()
public LoggingObjectType getObjectType()
public LoggingObjectInterface getParent()
public RepositoryDirectory getRepositoryDirectory()
public StepIOMetaInterface getStepIOMeta()
public List<StreamInterface> getOptionalStreams()
public void handleStreamSelection(StreamInterface stream)
stream
- The optional stream to handle.public void resetStepIoMeta()
public void searchInfoAndTargetSteps(List<StepMeta> steps)
steps
- the steps to referencepublic StepMetaInjectionInterface getStepMetaInjectionInterface()
public List<StepInjectionMetaEntry> getStepInjectionMetadataEntries(Class<?> PKG)
public KettleAttributeInterface findParent(List<KettleAttributeInterface> attributes, String parentId)
findParent
in interface StepAttributesInterface
public KettleAttributeInterface findAttribute(String key)
findAttribute
in interface StepAttributesInterface
public String getXmlCode(String attributeKey)
getXmlCode
in interface StepAttributesInterface
public String getRepCode(String attributeKey)
getRepCode
in interface StepAttributesInterface
public String getDescription(String attributeKey)
getDescription
in interface StepAttributesInterface
public String getTooltip(String attributeKey)
getTooltip
in interface StepAttributesInterface
public TransMeta.TransformationType[] getSupportedTransformationTypes()
public boolean hasRepositoryReferences()
public void lookupRepositoryReferences(Repository repository) throws KettleException
repository
- the repository to reference.
KettleException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |