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 String
APPLICATION_TYPE_ATOM_XML
static String
APPLICATION_TYPE_FORM_URLENCODED
static String
APPLICATION_TYPE_JSON
static String
APPLICATION_TYPE_OCTET_STREAM
static String
APPLICATION_TYPE_SVG_XML
static String
APPLICATION_TYPE_TEXT_PLAIN
static String
APPLICATION_TYPE_TEXT_XML
static String
APPLICATION_TYPE_XHTML
static String
APPLICATION_TYPE_XML
static String[]
APPLICATION_TYPES
static String
HTTP_METHOD_DELETE
static String
HTTP_METHOD_GET
static String
HTTP_METHOD_HEAD
static String
HTTP_METHOD_OPTIONS
static String
HTTP_METHOD_PATCH
static String
HTTP_METHOD_POST
static String
HTTP_METHOD_PUT
static 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 void
allocate(int nrheaders, int nrparamers)
Deprecated.void
allocate(int nrheaders, int nrparamers, int nrmatrixparameters)
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.String
getApplicationType()
GetterString
getBodyField()
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[]
getHeaderField()
String[]
getHeaderName()
String
getHttpLogin()
GetterString
getHttpPassword()
String[]
getMatrixParameterField()
String[]
getMatrixParameterName()
String
getMethod()
String
getMethodFieldName()
String[]
getParameterField()
String[]
getParameterName()
String
getProxyHost()
GetterString
getProxyPort()
GetterString
getResponseHeaderFieldName()
String
getResponseTimeFieldName()
String
getResultCodeFieldName()
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
getTrustStoreFile()
String
getTrustStorePassword()
String
getUrl()
String
getUrlField()
String
getXML()
Produces the XML string that describes this step's information.static boolean
isActiveBody(String method)
static boolean
isActiveParameters(String method)
boolean
isDynamicMethod()
boolean
isPreemptive()
boolean
isUrlInField()
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 repositoryvoid
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
setApplicationType(String applicationType)
Settervoid
setBodyField(String value)
void
setDefault()
Set default valuesvoid
setDynamicMethod(boolean dynamicMethod)
void
setFieldName(String resultName)
void
setHeaderField(String[] value)
void
setHeaderName(String[] value)
void
setHttpLogin(String httpLogin)
Settervoid
setHttpPassword(String httpPassword)
Settervoid
setMatrixParameterField(String[] value)
void
setMatrixParameterName(String[] value)
void
setMethod(String value)
void
setMethodFieldName(String methodFieldName)
void
setParameterField(String[] value)
void
setParameterName(String[] value)
void
setPreemptive(boolean preemptive)
void
setProxyHost(String proxyHost)
Settervoid
setProxyPort(String proxyPort)
Settervoid
setResponseHeaderFieldName(String responseHeaderFieldName)
void
setResponseTimeFieldName(String responseTimeFieldName)
void
setResultCodeFieldName(String resultCodeFieldName)
void
setTrustStoreFile(String trustStoreFile)
Settervoid
setTrustStorePassword(String trustStorePassword)
Settervoid
setUrl(String procedure)
void
setUrlField(String urlField)
void
setUrlInField(boolean urlInField)
boolean
supportsErrorHandling()
-
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: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
@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: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
-
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
-
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)
-
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.
-
supportsErrorHandling
public boolean supportsErrorHandling()
- Specified by:
supportsErrorHandling
in interfaceStepMetaInterface
- Overrides:
supportsErrorHandling
in 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)
-
-