Package org.pentaho.di.trans.steps.rest
Class RestMeta
- java.lang.Object
-
- org.pentaho.di.trans.step.BaseStepMeta
-
- org.pentaho.di.trans.steps.rest.RestMeta
-
- All Implemented Interfaces:
Cloneable,StepAttributesInterface,StepMetaInterface
public class RestMeta extends BaseStepMeta implements StepMetaInterface
- Since:
- 16-jan-2011
- Author:
- Samatar
-
-
Field Summary
Fields Modifier and Type Field Description static StringAPPLICATION_TYPE_ATOM_XMLstatic StringAPPLICATION_TYPE_FORM_URLENCODEDstatic StringAPPLICATION_TYPE_JSONstatic StringAPPLICATION_TYPE_OCTET_STREAMstatic StringAPPLICATION_TYPE_SVG_XMLstatic StringAPPLICATION_TYPE_TEXT_PLAINstatic StringAPPLICATION_TYPE_TEXT_XMLstatic StringAPPLICATION_TYPE_XHTMLstatic StringAPPLICATION_TYPE_XMLstatic String[]APPLICATION_TYPESstatic StringHTTP_METHOD_DELETEstatic StringHTTP_METHOD_GETstatic StringHTTP_METHOD_HEADstatic StringHTTP_METHOD_OPTIONSstatic StringHTTP_METHOD_PATCHstatic StringHTTP_METHOD_POSTstatic StringHTTP_METHOD_PUTstatic String[]HTTP_METHODS-
Fields inherited from class org.pentaho.di.trans.step.BaseStepMeta
attributes, databases, log, loggingObject, parentStepMeta, repository, STEP_ATTRIBUTES_FILE
-
-
Constructor Summary
Constructors Constructor Description RestMeta()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description voidallocate(int nrheaders, int nrparamers)Deprecated.voidallocate(int nrheaders, int nrparamers, int nrmatrixparameters)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.StringgetApplicationType()GetterStringgetBodyField()StringgetFieldName()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.String[]getHeaderField()String[]getHeaderName()StringgetHttpLogin()GetterStringgetHttpPassword()String[]getMatrixParameterField()String[]getMatrixParameterName()StringgetMethod()StringgetMethodFieldName()String[]getParameterField()String[]getParameterName()StringgetProxyHost()GetterStringgetProxyPort()GetterStringgetResponseHeaderFieldName()StringgetResponseTimeFieldName()StringgetResultCodeFieldName()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.StringgetTrustStoreFile()StringgetTrustStorePassword()StringgetUrl()StringgetUrlField()StringgetXML()Produces the XML string that describes this step's information.static booleanisActiveBody(String method)static booleanisActiveParameters(String method)booleanisDynamicMethod()booleanisPreemptive()booleanisUrlInField()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 repositoryvoidsaveRep(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 repositoryvoidsetApplicationType(String applicationType)SettervoidsetBodyField(String value)voidsetDefault()Set default valuesvoidsetDynamicMethod(boolean dynamicMethod)voidsetFieldName(String resultName)voidsetHeaderField(String[] value)voidsetHeaderName(String[] value)voidsetHttpLogin(String httpLogin)SettervoidsetHttpPassword(String httpPassword)SettervoidsetMatrixParameterField(String[] value)voidsetMatrixParameterName(String[] value)voidsetMethod(String value)voidsetMethodFieldName(String methodFieldName)voidsetParameterField(String[] value)voidsetParameterName(String[] value)voidsetPreemptive(boolean preemptive)voidsetProxyHost(String proxyHost)SettervoidsetProxyPort(String proxyPort)SettervoidsetResponseHeaderFieldName(String responseHeaderFieldName)voidsetResponseTimeFieldName(String responseTimeFieldName)voidsetResultCodeFieldName(String resultCodeFieldName)voidsetTrustStoreFile(String trustStoreFile)SettervoidsetTrustStorePassword(String trustStorePassword)SettervoidsetUrl(String procedure)voidsetUrlField(String urlField)voidsetUrlInField(boolean urlInField)booleansupportsErrorHandling()-
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
-
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
-
-
-
-
Field Detail
-
APPLICATION_TYPES
public static final String[] APPLICATION_TYPES
-
APPLICATION_TYPE_TEXT_PLAIN
public static final String APPLICATION_TYPE_TEXT_PLAIN
- See Also:
- Constant Field Values
-
APPLICATION_TYPE_XML
public static final String APPLICATION_TYPE_XML
- See Also:
- Constant Field Values
-
APPLICATION_TYPE_JSON
public static final String APPLICATION_TYPE_JSON
- See Also:
- Constant Field Values
-
APPLICATION_TYPE_OCTET_STREAM
public static final String APPLICATION_TYPE_OCTET_STREAM
- See Also:
- Constant Field Values
-
APPLICATION_TYPE_XHTML
public static final String APPLICATION_TYPE_XHTML
- See Also:
- Constant Field Values
-
APPLICATION_TYPE_FORM_URLENCODED
public static final String APPLICATION_TYPE_FORM_URLENCODED
- See Also:
- Constant Field Values
-
APPLICATION_TYPE_ATOM_XML
public static final String APPLICATION_TYPE_ATOM_XML
- See Also:
- Constant Field Values
-
APPLICATION_TYPE_SVG_XML
public static final String APPLICATION_TYPE_SVG_XML
- See Also:
- Constant Field Values
-
APPLICATION_TYPE_TEXT_XML
public static final String APPLICATION_TYPE_TEXT_XML
- See Also:
- Constant Field Values
-
HTTP_METHODS
public static final String[] HTTP_METHODS
-
HTTP_METHOD_GET
public static final String HTTP_METHOD_GET
- See Also:
- Constant Field Values
-
HTTP_METHOD_POST
public static final String HTTP_METHOD_POST
- See Also:
- Constant Field Values
-
HTTP_METHOD_PUT
public static final String HTTP_METHOD_PUT
- See Also:
- Constant Field Values
-
HTTP_METHOD_DELETE
public static final String HTTP_METHOD_DELETE
- See Also:
- Constant Field Values
-
HTTP_METHOD_HEAD
public static final String HTTP_METHOD_HEAD
- See Also:
- Constant Field Values
-
HTTP_METHOD_OPTIONS
public static final String HTTP_METHOD_OPTIONS
- See Also:
- Constant Field Values
-
HTTP_METHOD_PATCH
public static final String HTTP_METHOD_PATCH
- See Also:
- Constant Field Values
-
-
Method Detail
-
getMethod
public String getMethod()
- Returns:
- Returns the method.
-
setMethod
public void setMethod(String value)
- Parameters:
value- The method to set.
-
getBodyField
public String getBodyField()
- Returns:
- Returns the bodyField.
-
setBodyField
public void setBodyField(String value)
- Parameters:
value- The bodyField to set.
-
getHeaderName
public String[] getHeaderName()
- Returns:
- Returns the headerName.
-
setHeaderName
public void setHeaderName(String[] value)
- Parameters:
value- The headerName to set.
-
getParameterField
public String[] getParameterField()
- Returns:
- Returns the parameterField.
-
setParameterField
public void setParameterField(String[] value)
- Parameters:
value- The parameterField to set.
-
getParameterName
public String[] getParameterName()
- Returns:
- Returns the parameterName.
-
setParameterName
public void setParameterName(String[] value)
- Parameters:
value- The parameterName to set.
-
getMatrixParameterField
public String[] getMatrixParameterField()
- Returns:
- Returns the matrixParameterField.
-
setMatrixParameterField
public void setMatrixParameterField(String[] value)
- Parameters:
value- The matrixParameterField to set.
-
getMatrixParameterName
public String[] getMatrixParameterName()
- Returns:
- Returns the matrixParameterName.
-
setMatrixParameterName
public void setMatrixParameterName(String[] value)
- Parameters:
value- The matrixParameterName to set.
-
getHeaderField
public String[] getHeaderField()
- Returns:
- Returns the headerField.
-
setHeaderField
public void setHeaderField(String[] value)
- Parameters:
value- The headerField to set.
-
getUrl
public String getUrl()
- Returns:
- Returns the procedure.
-
setUrl
public void setUrl(String procedure)
- Parameters:
procedure- The procedure to set.
-
isUrlInField
public boolean isUrlInField()
- Returns:
- Is the url coded in a field?
-
setUrlInField
public void setUrlInField(boolean urlInField)
- Parameters:
urlInField- Is the url coded in a field?
-
isPreemptive
public boolean isPreemptive()
- Returns:
- Is preemptive?
-
setPreemptive
public void setPreemptive(boolean preemptive)
- Parameters:
preemptive- Ispreemptive?
-
isDynamicMethod
public boolean isDynamicMethod()
- Returns:
- Is the method defined in a field?
-
setDynamicMethod
public void setDynamicMethod(boolean dynamicMethod)
- Parameters:
dynamicMethod- If the method is defined in a field?
-
getMethodFieldName
public String getMethodFieldName()
- Returns:
- methodFieldName
-
setMethodFieldName
public void setMethodFieldName(String methodFieldName)
- Parameters:
methodFieldName-
-
getUrlField
public String getUrlField()
- Returns:
- The field name that contains the url.
-
setUrlField
public void setUrlField(String urlField)
- Parameters:
urlField- name of the field that contains the url
-
getFieldName
public String getFieldName()
- Returns:
- Returns the resultName.
-
setFieldName
public void setFieldName(String resultName)
- Parameters:
resultName- The resultName 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
@Deprecated public void allocate(int nrheaders, int nrparamers)
Deprecated.
-
allocate
public void allocate(int nrheaders, int nrparamers, int nrmatrixparameters)
-
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
-
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
-
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)
-
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.
-
supportsErrorHandling
public boolean supportsErrorHandling()
- Specified by:
supportsErrorHandlingin interfaceStepMetaInterface- Overrides:
supportsErrorHandlingin classBaseStepMeta- Returns:
- true if this step supports error "reporting" on rows: the ability to send rows to a certain target step.
-
getResultCodeFieldName
public String getResultCodeFieldName()
- Returns:
- the resultCodeFieldName
-
setResultCodeFieldName
public void setResultCodeFieldName(String resultCodeFieldName)
- Parameters:
resultCodeFieldName- the resultCodeFieldName to set
-
setProxyHost
public void setProxyHost(String proxyHost)
Setter- Parameters:
proxyHost-
-
getProxyHost
public String getProxyHost()
Getter- Returns:
-
setProxyPort
public void setProxyPort(String proxyPort)
Setter- Parameters:
proxyPort-
-
getProxyPort
public String getProxyPort()
Getter- Returns:
-
setApplicationType
public void setApplicationType(String applicationType)
Setter- Parameters:
applicationType-
-
getApplicationType
public String getApplicationType()
Getter- Returns:
-
setHttpLogin
public void setHttpLogin(String httpLogin)
Setter- Parameters:
httpLogin-
-
getHttpLogin
public String getHttpLogin()
Getter- Returns:
-
setHttpPassword
public void setHttpPassword(String httpPassword)
Setter- Parameters:
httpPassword-
-
getHttpPassword
public String getHttpPassword()
- Returns:
-
setTrustStoreFile
public void setTrustStoreFile(String trustStoreFile)
Setter- Parameters:
trustStoreFile-
-
getTrustStoreFile
public String getTrustStoreFile()
- Returns:
- trustStoreFile
-
setTrustStorePassword
public void setTrustStorePassword(String trustStorePassword)
Setter- Parameters:
trustStorePassword-
-
getTrustStorePassword
public String getTrustStorePassword()
- Returns:
- trustStorePassword
-
getResponseTimeFieldName
public String getResponseTimeFieldName()
-
setResponseTimeFieldName
public void setResponseTimeFieldName(String responseTimeFieldName)
-
getResponseHeaderFieldName
public String getResponseHeaderFieldName()
-
setResponseHeaderFieldName
public void setResponseHeaderFieldName(String responseHeaderFieldName)
-
isActiveBody
public static boolean isActiveBody(String method)
-
isActiveParameters
public static boolean isActiveParameters(String method)
-
-