Introduction
This page contains the index for the documentation on all the standard job entries in Pentaho Data Integration version 4.2
We invite everyone to add more details, tips and samples to this job entries pages.
| Name | Category | ID | Description | Main class |
|---|---|---|---|---|
| Abort job | Utility | ABORT | Abort the job | opdje.abort.JobEntryAbort |
| Add filenames to result | File management | ADD_RESULT_FILENAMES | Add filenames to result | opdje.addresultfilenames.JobEntryAddResultFilenames |
| BulkLoad from Mysql into file | Bulk loading | MYSQL_BULK_FILE | Load from a mysql table into a file | opdje.mysqlbulkfile.JobEntryMysqlBulkFile |
| BulkLoad into MSSQL | Bulk loading | MSSQL_BULK_LOAD | Load data from a file into a MSSQL table | opdje.mssqlbulkload.JobEntryMssqlBulkLoad |
| BulkLoad into Mysql | Bulk loading | MYSQL_BULK_LOAD | Load data from a file into a Mysql table | opdje.mysqlbulkload.JobEntryMysqlBulkLoad |
| Check Db connections | Conditions | CHECK_DB_CONNECTIONS | Check if we can connect to one or several databases. | opdje.checkdbconnection.JobEntryCheckDbConnections |
| Check files locked | Conditions | CHECK_FILES_LOCKED | Check if one or several files are locked by another process | opdje.checkfilelocked.JobEntryCheckFilesLocked |
| Check if a folder is empty | Conditions | FOLDER_IS_EMPTY | Check if a folder is empty | opdje.folderisempty.JobEntryFolderIsEmpty |
| Check if connected to repository | Repository | CONNECTED_TO_REPOSITORY | Return true if we are connected to a repository | opdje.connectedtorepository.JobEntryConnectedToRepository |
| Check if XML file is well formed | XML | XML_WELL_FORMED | Check if one or several XML files is/are well formed | opdje.xmlwellformed.JobEntryXMLWellFormed |
| Check webservice availability | Conditions | WEBSERVICE_AVAILABLE | Check if a webservice is available | opdje.webserviceavailable.JobEntryWebServiceAvailable |
| Checks if files exist | Conditions | FILES_EXIST | Checks if files exists | opdje.filesexist.JobEntryFilesExist |
| Columns exist in a table | Conditions | COLUMNS_EXIST | Check if one or several columns exist in a table on a specified connection | opdje.columnsexist.JobEntryColumnsExist |
| Compare folders | File management | FOLDERS_COMPARE | compare two folders (or two files) | opdje.folderscompare.JobEntryFoldersCompare |
| Convert file between DOS and UNIX | File management | DOS_UNIX_CONVERTER | Convert file content between DOS and UNIX. Converting to UNIX will replace CRLF (Carriage Return and line Feed) by LF (Line Feed) | opdje.dostounix.JobEntryDosToUnix |
| Copy Files | File management | COPY_FILES | Copy Files | opdje.copyfiles.JobEntryCopyFiles |
| Copy or Move result filenames | File management | COPY_MOVE_RESULT_FILENAMES | Copy or Move result filenames | opdje.copymoveresultfilenames.JobEntryCopyMoveResultFilenames |
| Create a folder | File management | CREATE_FOLDER | Create a folder | opdje.createfolder.JobEntryCreateFolder |
| Create file | File management | CREATE_FILE | Create (an empty) file | opdje.createfile.JobEntryCreateFile |
| Decrypt files with PGP | File encryption | PGP_DECRYPT_FILES | Decrypt files encrypted with PGP (Pretty Good Privacy). This job entry need GnuPG to work properly. | opdje.pgpdecryptfiles.JobEntryPGPDecryptFiles |
| Delete file | File management | DELETE_FILE | Delete a file | opdje.deletefile.JobEntryDeleteFile |
| Delete filenames from result | File management | DELETE_RESULT_FILENAMES | Delete filenames from result | opdje.deleteresultfilenames.JobEntryDeleteResultFilenames |
| Delete files | File management | DELETE_FILES | Delete files | opdje.deletefiles.JobEntryDeleteFiles |
| Delete folders | File management | DELETE_FOLDERS | Delete specified folders. Attention : if a the folder contains files, PDI will delete them all! | opdje.deletefolders.JobEntryDeleteFolders |
| Display Msgbox Info | Utility | MSGBOX_INFO | Display a simple Message box Information | opdje.msgboxinfo.JobEntryMsgBoxInfo |
| DTD Validator | XML | DTD_VALIDATOR | DTD Validator | opdje.dtdvalidator.JobEntryDTDValidator |
| Encrypt files with PGP | File encryption | PGP_ENCRYPT_FILES | Encrypt files with PGP (Pretty Good Privacy). This job entry need GnuPG to work properly. | opdje.pgpencryptfiles.JobEntryPGPEncryptFiles |
| Evaluate files metrics | Conditions | EVAL_FILES_METRICS | Evaluate files size or files count | opdje.evalfilesmetrics.JobEntryEvalFilesMetrics |
| Evaluate rows number in a table | Conditions | EVAL_TABLE_CONTENT | Evaluate the content of a table. You can also specify a SQL query. | opdje.evaluatetablecontent.JobEntryEvalTableContent |
| Example plugin | General | DummyJob | This is an example test job entry for a plugin | pdi.jobentry.dummy.JobEntryDummy |
| Export repository to XML file | Repository | EXPORT_REPOSITORY | Export repository to XML file | opdje.exportrepository.JobEntryExportRepository |
| File Compare | File management | FILE_COMPARE | Compare 2 files | opdje.filecompare.JobEntryFileCompare |
| File Exists | Conditions | FILE_EXISTS | Checks if a file exists | opdje.fileexists.JobEntryFileExists |
| FTP Delete | File transfer | FTP_DELETE | Delete files in a remote host | opdje.ftpdelete.JobEntryFTPDelete |
| Get a file with FTP | File transfer | FTP | Get files using FTP (File Transfer Protocol) | opdje.ftp.JobEntryFTP |
| Get a file with FTPS | File transfer | FTPS_GET | Get a file with FTP secure | opdje.ftpsget.JobEntryFTPSGet |
| Get a file with SFTP | File transfer | SFTP | Get files using Secure FTP (Secure File Transfer Protocol) | opdje.sftp.JobEntrySFTP |
| Get mails (POP3/IMAP) | GET_POP | Get mails (POP3/IMAP) server and save into a local folder | opdje.getpop.JobEntryGetPOP | |
| Hadoop job executor | Hadoop | HadoopJobExecutorPlugin | Execute a map/reduce job contained in a jar file | opdje.hadoopjobexecutor.JobEntryHadoopJobExecutor |
| HTTP | File management | HTTP | Gets or uploads a file using HTTP (HyperText Transfer Protocol) | opdje.http.JobEntryHTTP |
| JavaScript | Scripting | EVAL | Evaluates the result of the execution of a previous job entry | opdje.eval.JobEntryEval |
| Job | General | JOB | Executes a job | opdje.job.JobEntryJob |
| Sends an e-Mail | opdje.mail.JobEntryMail | |||
| Mail validator | JobCategory.Category.Mail_VALIDATOR | Check the validity of an email address ( SNMP trap to a target host | opdje.mailvalidator.JobEntryMailValidator | |
| Move Files | File management | MOVE_FILES | Move Files | opdje.movefiles.JobEntryMoveFiles |
| MS Access Bulk Load | Bulk loading | MS_ACCESS_BULK_LOAD | Load data into a Microsoft Access table from CSV file format. ATTENTION, at the moment only the insertion is available! If target table exists, a new one will be created and data inserted. | opdje.msaccessbulkload.JobEntryMSAccessBulkLoad |
| Palo Cube Create |
Palo |
PALO_CUBE_CREATE | Creates a cube on a Palo server |
opdje.palo.JobEntryCubeCreate |
| Palo Cube Delete |
Palo |
PALO_CUBE_DELETE | Deletes a cube on a Palo server |
opdje.palo.JobEntryCubeDelete |
| Pig Script Executor | Hadoop | HadoopPigScriptExecutorPlugin | Execute a Pig script on a Hadoop cluster | opdje.pig.JobEntryPigScriptExecutor |
| Ping a host | Utility | PING | Ping a host | opdje.ping.JobEntryPing |
| Put a file with FTP | File transfer | FTP_PUT | Put a file with FTP | opdje.ftpput.JobEntryFTPPUT |
| Put a file with SFTP | File transfer | SFTPPUT | Put files using SFTP (Secure File Transfer Protocol) | opdje.sftpput.JobEntrySFTPPUT |
| Send information using Syslog | Utility | SYSLOG | Sends information to another server using the Syslog protocol. |
opdje.syslog.JobEntrySyslog |
| Send SNMP trap | Utility | SNMP_TRAP | Send SNMP trap to a target host | opdje.snmptrap.JobEntrySNMPTrap |
| Set variables | General | SET_VARIABLES | Set one or several variables. | opdje.setvariables.JobEntrySetVariables |
| Shell | Scripting | SHELL | Executes a shell script | opdje.shell.JobEntryShell |
| Simple evaluation | Conditions | SIMPLE_EVAL | Evaluate one field or variable | opdje.simpleeval.JobEntrySimpleEval |
| SQL | Scripting | SQL | Executes SQL on a certain database connection | opdje.sql.JobEntrySQL |
| SSH2 Get | File transfer | SSH2_GET | Get files using SSH2 | opdje.ssh2get.JobEntrySSH2GET |
| SSH2 Put | File transfer | SSH2_PUT | Put files in a remote host using SSH2 | opdje.ssh2put.JobEntrySSH2PUT |
| Success | General | SUCCESS | Success | opdje.success.JobEntrySuccess |
| Table exists | Conditions | TABLE_EXISTS | Checks if a table exists on a database connection | opdje.tableexists.JobEntryTableExists |
| Talend Job Execution | Utility | TALEND_JOB_EXEC | This job entry executes an exported Talend Job | opdje.talendjobexec.JobEntryTalendJobExec |
| Transformation | General | TRANS | Executes a transformation | opdje.trans.JobEntryTrans |
| Truncate tables | Utility | TRUNCATE_TABLES | Truncate one or several tables. | opdje.truncatetables.JobEntryTruncateTables |
| Unzip file | File management | UNZIP | Unzip file in a targer folder | opdje.unzip.JobEntryUnZip |
| Upload files to FTPS | File transfer | FTPS_PUT | Upload files to a FTP secure | opdje.ftpsput.JobEntryFTPSPUT |
| Verify file signature with PGP | File encryption | PGP_VERIFY_FILES | Verify file signature with PGP (Pretty Good Privacy). This job entry need GnuPG to work properly. | opdje.pgpverify.JobEntryPGPVerify |
| Wait for | Conditions | DELAY | Wait for a delay | opdje.delay.JobEntryDelay |
| Wait for file | File management | WAIT_FOR_FILE | Wait for a file | opdje.waitforfile.JobEntryWaitForFile |
| Wait for SQL | Utility | WAIT_FOR_SQL | Scan a database and success when a specified condition on returned rows is true. | opdje.waitforsql.JobEntryWaitForSQL |
| Write to file | File management | WRITE_TO_FILE | Write text content to file. | opdje.writetofile.JobEntryWriteToFile |
| Write To Log | Utility | WRITE_TO_LOG | Write message to log | opdje.writetolog.JobEntryWriteToLog |
| XSD Validator | XML | XSD_VALIDATOR | XSD Validator | opdje.xsdvalidator.JobEntryXSDValidator |
| XSL Transformation | XML | XSLT | Make an XSL Transformation | opdje.xslt.JobEntryXSLT |
| Zip file | File management | ZIP_FILE | Zip files from a directory and process files | opdje.zipfile.JobEntryZipFile |
Page:
Abort Job
Page: Add filenames to result
Page: Bulkload into MySQL
Page: Check if a folder is empty
Page: Check if XML file is well formed
Page: Check webservice availability
Page: Columns exist in a table
Page: Compare folders
Page: Copy Files
Page: Create a file
Page: Create a folder
Page: Delete a file
Page: Delete filenames from result
Page: Delete Files
Page: Delete folders
Page: Display Msgbox info
Page: DTD Validator (Job Entry)
Page: Dummy Job Entry
Page: Export repository to XML file
Page: File compare
Page: File Exists (Job Entry)
Page: Get a file with FTP
Page: Get a file with SFTP
Page: Get Mails from POP
Page: HTTP
Page: Job (Job Entry)
Page: Mail
Page: Move files
Page: Palo Cube Create
Page: Palo Cube Delete
Page: Ping a host
Page: Put a file with SFTP
Page: Shell
Page: SQL
Page: Start
Page: Success
Page: Table Exists (Job Entry)
Page: Transformation (job entry)
Page: Truncate tables
Page: Unzip file
Page: Wait for
Page: Wait for a file
Page: Write to log
Page: XSD Validator (Job Entry)
Page: XSL Transformation (Job Entry)
Page: Zip files
Page: Add filenames to result
Page: Bulkload into MySQL
Page: Check if a folder is empty
Page: Check if XML file is well formed
Page: Check webservice availability
Page: Columns exist in a table
Page: Compare folders
Page: Copy Files
Page: Create a file
Page: Create a folder
Page: Delete a file
Page: Delete filenames from result
Page: Delete Files
Page: Delete folders
Page: Display Msgbox info
Page: DTD Validator (Job Entry)
Page: Dummy Job Entry
Page: Export repository to XML file
Page: File compare
Page: File Exists (Job Entry)
Page: Get a file with FTP
Page: Get a file with SFTP
Page: Get Mails from POP
Page: HTTP
Page: Job (Job Entry)
Page: Mail
Page: Move files
Page: Palo Cube Create
Page: Palo Cube Delete
Page: Ping a host
Page: Put a file with SFTP
Page: Shell
Page: SQL
Page: Start
Page: Success
Page: Table Exists (Job Entry)
Page: Transformation (job entry)
Page: Truncate tables
Page: Unzip file
Page: Wait for
Page: Wait for a file
Page: Write to log
Page: XSD Validator (Job Entry)
Page: XSL Transformation (Job Entry)
Page: Zip files