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 int
DEFAULT_CLOSE_CONNECTIONS_TIME
static int
DEFAULT_CONNECTION_TIMEOUT
static int
DEFAULT_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 void
allocate(int nrargs, int nrqueryparams)
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[]
getArgumentField()
String[]
getArgumentParameter()
String
getCloseIdleConnectionsTime()
String
getConnectionTimeout()
String
getEncoding()
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[]
getHeaderParameter()
String
getHttpLogin()
GetterString
getHttpPassword()
String
getProxyHost()
GetterString
getProxyPort()
GetterString
getResponseHeaderFieldName()
String
getResponseTimeFieldName()
String
getResultCodeFieldName()
String
getSocketTimeout()
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
getUrl()
String
getUrlField()
String
getXML()
Produces the XML string that describes this step's information.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
setArgumentField(String[] argument)
void
setArgumentParameter(String[] argumentDirection)
void
setCloseIdleConnectionsTime(String closeIdleConnectionsTime)
void
setConnectionTimeout(String connectionTimeout)
void
setDefault()
Set default valuesvoid
setEncoding(String encoding)
void
setFieldName(String resultName)
void
setHeaderField(String[] headerField)
void
setHeaderParameter(String[] headerParameter)
void
setHttpLogin(String httpLogin)
Settervoid
setHttpPassword(String httpPassword)
Settervoid
setProxyHost(String proxyHost)
Settervoid
setProxyPort(String proxyPort)
Settervoid
setResponseHeaderFieldName(String responseHeaderFieldName)
void
setResponseTimeFieldName(String responseTimeFieldName)
void
setResultCodeFieldName(String resultCodeFieldName)
void
setSocketTimeout(String socketTimeout)
void
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
-
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: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 nrargs, int nrqueryparams)
-
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.
-
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)
-
-