org.pentaho.di.job.entries.http
Class JobEntryHTTP
java.lang.Object
org.pentaho.di.job.entry.JobEntryBase
org.pentaho.di.job.entries.http.JobEntryHTTP
- All Implemented Interfaces:
- Cloneable, org.pentaho.di.core.CheckResultSourceInterface, org.pentaho.di.core.variables.VariableSpace, JobEntryInterface, ResourceHolderInterface
public class JobEntryHTTP
- extends JobEntryBase
- implements Cloneable, JobEntryInterface
This defines an HTTP job entry.
- Since:
- 05-11-2003
- Author:
- Matt
Method Summary |
void |
check(List<org.pentaho.di.core.CheckResultInterface> remarks,
JobMeta jobMeta)
Support for overrides not having to put in a check method |
Object |
clone()
|
boolean |
evaluates()
check whether or not this job entry evaluates. |
org.pentaho.di.core.Result |
execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
We made this one synchronized in the JVM because otherwise, this is not thread safe. |
String |
getNonProxyHosts()
|
String |
getPassword()
|
String |
getProxyHostname()
|
String |
getProxyPort()
|
List<ResourceReference> |
getResourceDependencies(JobMeta jobMeta)
Get a list of all the resource dependencies that the step is depending
on. |
String |
getTargetFilename()
|
String |
getTargetFilenameExtention()
|
String |
getUploadFilename()
|
String |
getUrl()
|
String |
getUrlFieldname()
|
String |
getUsername()
|
String |
getXML()
|
boolean |
isDateTimeAdded()
|
boolean |
isFileAppended()
|
boolean |
isRunForEveryRow()
|
void |
loadRep(Repository rep,
long id_jobentry,
List<org.pentaho.di.core.database.DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
loadXML(Node entrynode,
List<org.pentaho.di.core.database.DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep)
|
void |
saveRep(Repository rep,
long id_job)
|
void |
setDateTimeAdded(boolean dateTimeAdded)
|
void |
setFileAppended(boolean fileAppended)
|
void |
setNonProxyHosts(String nonProxyHosts)
|
void |
setPassword(String password)
|
void |
setProxyHostname(String proxyHostname)
|
void |
setProxyPort(String proxyPort)
|
void |
setRunForEveryRow(boolean runForEveryRow)
|
void |
setTargetFilename(String targetFilename)
|
void |
setTargetFilenameExtention(String uploadFilenameExtention)
|
void |
setUploadFilename(String uploadFilename)
|
void |
setUrl(String url)
|
void |
setUrlFieldname(String getFieldname)
|
void |
setUsername(String username)
|
Methods inherited from class org.pentaho.di.job.entry.JobEntryBase |
clear, copyVariablesFrom, environmentSubstitute, environmentSubstitute, exportResources, getBooleanValueOfVariable, getConfigId, getDescription, getDialogClassName, getFilename, getHolderType, getID, getJobEntryType, getName, getParentVariableSpace, getPluginID, getRealFilename, getSQLStatements, getSQLStatements, getTypeCode, getTypeCode, getTypeDesc, getTypeDesc, getTypeId, getUsedDatabaseConnections, getVariable, getVariable, hasChanged, initializeVariablesFrom, injectVariables, isDummy, isEvaluation, isFTP, isHTTP, isJob, isMail, isSFTP, isShell, isSpecial, isStart, isTransformation, isUnconditional, listVariables, loadXML, parseRepositoryObjects, resetErrorsBeforeExecution, setChanged, setChanged, setConfigId, setDescription, setID, setJobEntryType, setName, setParentVariableSpace, setPluginID, setVariable, shareVariablesWith, toString |
Methods inherited from interface org.pentaho.di.job.entry.JobEntryInterface |
clear, exportResources, getConfigId, getDescription, getDialogClassName, getFilename, getID, getJobEntryType, getName, getPluginID, getRealFilename, getSQLStatements, getSQLStatements, getTypeCode, getUsedDatabaseConnections, hasChanged, isDummy, isEvaluation, isJob, isMail, isShell, isSpecial, isStart, isTransformation, isUnconditional, resetErrorsBeforeExecution, setChanged, setChanged, setConfigId, setDescription, setID, setJobEntryType, setName, setPluginID |
JobEntryHTTP
public JobEntryHTTP(String n)
JobEntryHTTP
public JobEntryHTTP()
JobEntryHTTP
public JobEntryHTTP(JobEntryBase jeb)
clone
public Object clone()
- Specified by:
clone
in interface JobEntryInterface
- Overrides:
clone
in class JobEntryBase
getXML
public String getXML()
- Specified by:
getXML
in interface JobEntryInterface
- Overrides:
getXML
in class JobEntryBase
loadXML
public void loadXML(Node entrynode,
List<org.pentaho.di.core.database.DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep)
throws org.pentaho.di.core.exception.KettleXMLException
- Specified by:
loadXML
in interface JobEntryInterface
- Throws:
org.pentaho.di.core.exception.KettleXMLException
loadRep
public void loadRep(Repository rep,
long id_jobentry,
List<org.pentaho.di.core.database.DatabaseMeta> databases,
List<SlaveServer> slaveServers)
throws org.pentaho.di.core.exception.KettleException
- Specified by:
loadRep
in interface JobEntryInterface
- Overrides:
loadRep
in class JobEntryBase
- Throws:
org.pentaho.di.core.exception.KettleException
saveRep
public void saveRep(Repository rep,
long id_job)
throws org.pentaho.di.core.exception.KettleException
- Specified by:
saveRep
in interface JobEntryInterface
- Overrides:
saveRep
in class JobEntryBase
- Throws:
org.pentaho.di.core.exception.KettleException
getUrl
public String getUrl()
- Returns:
- Returns the URL.
setUrl
public void setUrl(String url)
- Parameters:
url
- The URL to set.
getTargetFilename
public String getTargetFilename()
- Returns:
- Returns the target filename.
setTargetFilename
public void setTargetFilename(String targetFilename)
- Parameters:
targetFilename
- The target filename to set.
getNonProxyHosts
public String getNonProxyHosts()
setNonProxyHosts
public void setNonProxyHosts(String nonProxyHosts)
getPassword
public String getPassword()
setPassword
public void setPassword(String password)
getProxyHostname
public String getProxyHostname()
setProxyHostname
public void setProxyHostname(String proxyHostname)
getProxyPort
public String getProxyPort()
setProxyPort
public void setProxyPort(String proxyPort)
getUsername
public String getUsername()
setUsername
public void setUsername(String username)
execute
public org.pentaho.di.core.Result execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
- We made this one synchronized in the JVM because otherwise, this is not thread safe.
In that case if (on an application server for example) several HTTP's are running at the same time,
you get into problems because the System.setProperty() calls are system wide!
- Specified by:
execute
in interface JobEntryInterface
evaluates
public boolean evaluates()
- Description copied from class:
JobEntryBase
- check whether or not this job entry evaluates.
- Specified by:
evaluates
in interface JobEntryInterface
- Overrides:
evaluates
in class JobEntryBase
- Returns:
- true if the job entry evaluates
getUploadFilename
public String getUploadFilename()
setUploadFilename
public void setUploadFilename(String uploadFilename)
getUrlFieldname
public String getUrlFieldname()
- Returns:
- Returns the getFieldname.
setUrlFieldname
public void setUrlFieldname(String getFieldname)
- Parameters:
getFieldname
- The getFieldname to set.
isRunForEveryRow
public boolean isRunForEveryRow()
- Returns:
- Returns the runForEveryRow.
setRunForEveryRow
public void setRunForEveryRow(boolean runForEveryRow)
- Parameters:
runForEveryRow
- The runForEveryRow to set.
isFileAppended
public boolean isFileAppended()
- Returns:
- Returns the fileAppended.
setFileAppended
public void setFileAppended(boolean fileAppended)
- Parameters:
fileAppended
- The fileAppended to set.
isDateTimeAdded
public boolean isDateTimeAdded()
- Returns:
- Returns the dateTimeAdded.
setDateTimeAdded
public void setDateTimeAdded(boolean dateTimeAdded)
- Parameters:
dateTimeAdded
- The dateTimeAdded to set.
getTargetFilenameExtention
public String getTargetFilenameExtention()
- Returns:
- Returns the uploadFilenameExtention.
setTargetFilenameExtention
public void setTargetFilenameExtention(String uploadFilenameExtention)
- Parameters:
uploadFilenameExtention
- The uploadFilenameExtention to set.
getResourceDependencies
public List<ResourceReference> getResourceDependencies(JobMeta jobMeta)
- Description copied from class:
JobEntryBase
- Get a list of all the resource dependencies that the step is depending
on.
- Specified by:
getResourceDependencies
in interface JobEntryInterface
- Overrides:
getResourceDependencies
in class JobEntryBase
- Returns:
- a list of all the resource dependencies that the step is
depending on
check
public void check(List<org.pentaho.di.core.CheckResultInterface> remarks,
JobMeta jobMeta)
- Description copied from class:
JobEntryBase
- Support for overrides not having to put in a check method
- Specified by:
check
in interface JobEntryInterface
- Overrides:
check
in class JobEntryBase
- Parameters:
remarks
- CheckResults from checking the job entryjobMeta
- JobMeta information letting threading back to the JobMeta possible