Package org.pentaho.di.trans.steps.http
Class HTTPMeta
- java.lang.Object
-
- org.pentaho.di.trans.step.BaseStepMeta
-
- org.pentaho.di.trans.steps.http.HTTPMeta
-
- All Implemented Interfaces:
Cloneable,StepAttributesInterface,StepMetaInterface
public class HTTPMeta extends BaseStepMeta implements StepMetaInterface
-
-
Field Summary
Fields Modifier and Type Field Description static intDEFAULT_CLOSE_CONNECTIONS_TIMEstatic intDEFAULT_CONNECTION_TIMEOUTstatic intDEFAULT_SOCKET_TIMEOUT-
Fields inherited from class org.pentaho.di.trans.step.BaseStepMeta
attributes, databases, log, loggingObject, parentStepMeta, repository, STEP_ATTRIBUTES_FILE
-
-
Constructor Summary
Constructors Constructor Description HTTPMeta()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidallocate(int nrargs, int nrqueryparams)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.String[]getArgumentField()String[]getArgumentParameter()StringgetCloseIdleConnectionsTime()StringgetConnectionTimeout()StringgetEncoding()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[]getHeaderParameter()StringgetHttpLogin()GetterStringgetHttpPassword()StringgetProxyHost()GetterStringgetProxyPort()GetterStringgetResponseHeaderFieldName()StringgetResponseTimeFieldName()StringgetResultCodeFieldName()StringgetSocketTimeout()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.StringgetUrl()StringgetUrlField()StringgetXML()Produces the XML string that describes this step's information.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 repositoryvoidsetArgumentField(String[] argument)voidsetArgumentParameter(String[] argumentDirection)voidsetCloseIdleConnectionsTime(String closeIdleConnectionsTime)voidsetConnectionTimeout(String connectionTimeout)voidsetDefault()Set default valuesvoidsetEncoding(String encoding)voidsetFieldName(String resultName)voidsetHeaderField(String[] headerField)voidsetHeaderParameter(String[] headerParameter)voidsetHttpLogin(String httpLogin)SettervoidsetHttpPassword(String httpPassword)SettervoidsetProxyHost(String proxyHost)SettervoidsetProxyPort(String proxyPort)SettervoidsetResponseHeaderFieldName(String responseHeaderFieldName)voidsetResponseTimeFieldName(String responseTimeFieldName)voidsetResultCodeFieldName(String resultCodeFieldName)voidsetSocketTimeout(String socketTimeout)voidsetUrl(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
-
DEFAULT_SOCKET_TIMEOUT
public static final int DEFAULT_SOCKET_TIMEOUT
- See Also:
- Constant Field Values
-
DEFAULT_CONNECTION_TIMEOUT
public static final int DEFAULT_CONNECTION_TIMEOUT
- See Also:
- Constant Field Values
-
DEFAULT_CLOSE_CONNECTIONS_TIME
public static final int DEFAULT_CLOSE_CONNECTIONS_TIME
- See Also:
- Constant Field Values
-
-
Method Detail
-
getConnectionTimeout
public String getConnectionTimeout()
- Returns:
- Returns the connectionTimeout.
-
setConnectionTimeout
public void setConnectionTimeout(String connectionTimeout)
- Parameters:
connectionTimeout- The connectionTimeout to set.
-
getCloseIdleConnectionsTime
public String getCloseIdleConnectionsTime()
- Returns:
- Returns the closeIdleConnectionsTime.
-
setCloseIdleConnectionsTime
public void setCloseIdleConnectionsTime(String closeIdleConnectionsTime)
- Parameters:
connectionTimeout- The connectionTimeout to set.
-
getSocketTimeout
public String getSocketTimeout()
- Returns:
- Returns the socketTimeout.
-
setSocketTimeout
public void setSocketTimeout(String socketTimeout)
- Parameters:
socketTimeout- The socketTimeout to set.
-
getArgumentField
public String[] getArgumentField()
- Returns:
- Returns the argument.
-
setArgumentField
public void setArgumentField(String[] argument)
- Parameters:
argument- The argument to set.
-
getHeaderField
public String[] getHeaderField()
- Returns:
- Returns the headerFields.
-
setHeaderField
public void setHeaderField(String[] headerField)
- Parameters:
headerField- The headerField to set.
-
getArgumentParameter
public String[] getArgumentParameter()
- Returns:
- Returns the argumentDirection.
-
setArgumentParameter
public void setArgumentParameter(String[] argumentDirection)
- Parameters:
argumentDirection- The argumentDirection to set.
-
getHeaderParameter
public String[] getHeaderParameter()
- Returns:
- Returns the headerParameter.
-
setHeaderParameter
public void setHeaderParameter(String[] headerParameter)
- Parameters:
headerParameter- The headerParameter to set.
-
getUrl
public String getUrl()
- Returns:
- Returns the procedure.
-
setUrl
public void setUrl(String procedure)
- Parameters:
procedure- The procedure to set.
-
getFieldName
public String getFieldName()
- Returns:
- Returns the resultName.
-
setFieldName
public void setFieldName(String resultName)
- Parameters:
resultName- The resultName 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?
-
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
-
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 nrargs, int nrqueryparams)
-
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.
-
getEncoding
public String getEncoding()
- Returns:
- the encoding
-
setEncoding
public void setEncoding(String encoding)
- Parameters:
encoding- the encoding 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:
-
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:
-
getResultCodeFieldName
public String getResultCodeFieldName()
- Returns:
- the resultCodeFieldName
-
setResultCodeFieldName
public void setResultCodeFieldName(String resultCodeFieldName)
- Parameters:
resultCodeFieldName- the resultCodeFieldName to set
-
getResponseTimeFieldName
public String getResponseTimeFieldName()
-
setResponseTimeFieldName
public void setResponseTimeFieldName(String responseTimeFieldName)
-
getResponseHeaderFieldName
public String getResponseHeaderFieldName()
-
setResponseHeaderFieldName
public void setResponseHeaderFieldName(String responseHeaderFieldName)
-
-